From 5657bf79a1c3c7768446296c11a627fab5ef61f5 Mon Sep 17 00:00:00 2001 From: Ankur Goenka Date: Wed, 5 Sep 2018 18:44:30 -0700 Subject: [PATCH] FlinkServerDriver port 0 usage documentation --- .../beam/runners/flink/FlinkJobServerDriver.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 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 index 0f567f6c6d579..7b0e55f70e644 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 @@ -55,10 +55,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")