You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ib...@apache.org on 2020/07/09 20:42:36 UTC
[beam] branch master updated: [BEAM-10432] Improve error message
for missing pipeline options.
This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 399a13c [BEAM-10432] Improve error message for missing pipeline options.
new 1ee1f15 Merge pull request #12207 from ibzib/BEAM-10432
399a13c is described below
commit 399a13ccc51e93eea8a7e7965bd3a5eb32909210
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Thu Jul 9 11:08:35 2020 -0700
[BEAM-10432] Improve error message for missing pipeline options.
---
.../src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index b838458..6a4e265 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -258,7 +258,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
}
if (missing.size() > 0) {
throw new IllegalArgumentException(
- "Missing required values: " + Joiner.on(',').join(missing));
+ "Missing required pipeline options: " + Joiner.on(',').join(missing));
}
validateWorkerSettings(PipelineOptionsValidator.validate(GcpOptions.class, options));