You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2019/03/27 18:07:29 UTC

[beam] branch master updated: Correct flag name in warning (#8138)

This is an automated email from the ASF dual-hosted git repository.

altay 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 c2c85fb  Correct flag name in warning (#8138)
c2c85fb is described below

commit c2c85fbf1ec9d0c73555b4399c4e1d5a127dc111
Author: Ahmet Altay <aa...@gmail.com>
AuthorDate: Wed Mar 27 11:07:19 2019 -0700

    Correct flag name in warning (#8138)
    
    Correct the flag name of enable_streaming_engine in the warning text.
---
 sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index 957c903..486268e 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -377,9 +377,9 @@ class DataflowRunner(PipelineRunner):
         if ("enable_windmill_service" in debug_options.experiments
             or "enable_streaming_engine" in debug_options.experiments):
           raise ValueError("""Streaming engine both disabled and enabled:
-          enableStreamingEngine is set to false, but enable_windmill_service
+          enable_streaming_engine flag is not set, but enable_windmill_service
           and/or enable_streaming_engine are present. It is recommended you
-          only set enableStreamingEngine.""")
+          only set the enable_streaming_engine flag.""")
 
     # TODO(BEAM-6664): Remove once Dataflow supports --dataflow_kms_key.
     if google_cloud_options.dataflow_kms_key is not None: