Increments major version used by Dataflow runner to 5
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1811458b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1811458b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1811458b Branch: refs/heads/master Commit: 1811458b0c33fba0dde909fc655452ad8a37c9f9 Parents: 894461e Author: Chamikara Jayalath <chamik...@google.com> Authored: Mon Jan 23 10:25:28 2017 -0800 Committer: Chamikara Jayalath <chamik...@google.com> Committed: Mon Jan 23 10:25:28 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/dataflow_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/1811458b/sdks/python/apache_beam/runners/dataflow_runner.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow_runner.py index 31d3386..abcc764 100644 --- a/sdks/python/apache_beam/runners/dataflow_runner.py +++ b/sdks/python/apache_beam/runners/dataflow_runner.py @@ -62,7 +62,7 @@ class DataflowRunner(PipelineRunner): # Environment version information. It is passed to the service during a # a job submission and is used by the service to establish what features # are expected by the workers. - BATCH_ENVIRONMENT_MAJOR_VERSION = '4' + BATCH_ENVIRONMENT_MAJOR_VERSION = '5' STREAMING_ENVIRONMENT_MAJOR_VERSION = '0' def __init__(self, cache=None, blocking=False):