You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2019/03/25 18:40:54 UTC
[beam] branch master updated: Revert & improve error message that
advises to use unsupported experiment
This is an automated email from the ASF dual-hosted git repository.
kenn 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 375aee5 Revert & improve error message that advises to use unsupported experiment
new c8bceba Merge pull request #8122: Revert error message that advises to use unsupported experiment
375aee5 is described below
commit 375aee532b64a327b5451a20111e8c82c6249653
Author: Kenneth Knowles <kl...@google.com>
AuthorDate: Fri Mar 22 13:47:30 2019 -0700
Revert & improve error message that advises to use unsupported experiment
---
.../main/java/org/apache/beam/runners/dataflow/DataflowRunner.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
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 2297f4c..d7b231e 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
@@ -897,9 +897,9 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
if (Utf8.encodedLength(newJob.toString()) >= CREATE_JOB_REQUEST_LIMIT_BYTES) {
errorMessages =
"The size of the serialized JSON representation of the pipeline "
- + "exceeds the allowable limit for the API. Use experiment "
- + "'upload_graph' (--experiments=upload_graph) to direct the runner to "
- + "upload the JSON to your GCS staging bucket instead of embedding in the API request.";
+ + "exceeds the allowable limit. "
+ + "For more information, please see the documentation on job submission:\n"
+ + "https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#jobs";
} else {
errorMessages = e.getDetails().getMessage();
}