Repository: beam Updated Branches: refs/heads/master 509baac58 -> 983a44926
Update Dataflow BATCH_ENVIRONMENT_MAJOR_VERSION to 6 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39e8d37e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39e8d37e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/39e8d37e Branch: refs/heads/master Commit: 39e8d37ee95709d07a74c9df866059871d5585f5 Parents: 509baac Author: Charles Chen <[email protected]> Authored: Mon May 22 13:03:38 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Mon May 22 13:55:39 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/39e8d37e/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py index 0ecd22a..a05e582 100644 --- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py +++ b/sdks/python/apache_beam/runners/dataflow/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 = '5' + BATCH_ENVIRONMENT_MAJOR_VERSION = '6' STREAMING_ENVIRONMENT_MAJOR_VERSION = '0' def __init__(self, cache=None):
