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 index 5d82587dc72b5..2096cb9855012 100644 --- 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")