You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by go...@apache.org on 2020/04/01 03:29:27 UTC
[beam] branch master updated: [BEAM-9263] Bump up python sdk
dataflow environment major versions
This is an automated email from the ASF dual-hosted git repository.
goenka 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 9a17b33 [BEAM-9263] Bump up python sdk dataflow environment major versions
new e9cd938 Merge pull request #10870 from y1chi/BEAM-9263
9a17b33 is described below
commit 9a17b334cf3c661b10a206acf7e5bd285c4b84d3
Author: Yichi Zhang <zy...@google.com>
AuthorDate: Mon Feb 10 10:57:55 2020 -0800
[BEAM-9263] Bump up python sdk dataflow environment major versions
---
runners/google-cloud-dataflow-java/build.gradle | 4 ++--
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle
index 8fbc4da..9a8e003 100644
--- a/runners/google-cloud-dataflow-java/build.gradle
+++ b/runners/google-cloud-dataflow-java/build.gradle
@@ -37,8 +37,8 @@ evaluationDependsOn(":sdks:java:container")
processResources {
filter org.apache.tools.ant.filters.ReplaceTokens, tokens: [
- 'dataflow.legacy_environment_major_version' : '7',
- 'dataflow.fnapi_environment_major_version' : '7',
+ 'dataflow.legacy_environment_major_version' : '8',
+ 'dataflow.fnapi_environment_major_version' : '8',
'dataflow.container_version' : 'beam-master-20200227'
]
}
diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
index a46e140..8b4e169 100644
--- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
+++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -70,8 +70,8 @@ from apache_beam.utils import proto_utils
# 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.
-_LEGACY_ENVIRONMENT_MAJOR_VERSION = '7'
-_FNAPI_ENVIRONMENT_MAJOR_VERSION = '7'
+_LEGACY_ENVIRONMENT_MAJOR_VERSION = '8'
+_FNAPI_ENVIRONMENT_MAJOR_VERSION = '8'
_LOGGER = logging.getLogger(__name__)