Merge pull request apache#6341: [BEAM-4130] Updating FlinkJobServerDr…

…iver for port 0 usage
cosmoskitten · Oct 2, 2018 · 0c91e0c · 0c91e0c
2 parents e79918c + 5657bf7
commit 0c91e0c
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java
@@ -57,10 +57,16 @@ public static class ServerConfiguration {
     @Option(name = "--job-host", usage = "The job server host name")
     private String host = "";
 
-    @Option(name = "--job-port", usage = "The job service port. (Default: 8099)")
+    @Option(
+      name = "--job-port",
+      usage = "The job service port. 0 to use a dynamic port. (Default: 8099)"
+    )
     private int port = 8099;
 
-    @Option(name = "--artifact-port", usage = "The artifact service port. (Default: 8098)")
+    @Option(
+      name = "--artifact-port",
+      usage = "The artifact service port. 0 to use a dynamic port. (Default: 8098)"
+    )
     private int artifactPort = 8098;
 
     @Option(name = "--artifacts-dir", usage = "The location to store staged artifact files")