This is an automated email from the ASF dual-hosted git repository.
yichi 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 818ee3b Revert "Avoid apiary submission of job graph when it is not
needed. (#15458)"
new f11a5bb Merge pull request #15592 from robertwb/no-upload-graph
818ee3b is described below
commit 818ee3bb384e890dc55fa937eee028ea4d1fd61e
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Fri Sep 24 16:29:07 2021 -0700
Revert "Avoid apiary submission of job graph when it is not needed.
(#15458)"
This reverts commit a63e15f714765f4f89d166c12430ee433a695e51.
This avoids regressions from missing display data that was being copied from
the v1beta3 graph.
---
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 7 -------
1 file changed, 7 deletions(-)
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index 29a6016..bbaf52c 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -508,13 +508,6 @@ class DataflowRunner(PipelineRunner):
# in the proto representation of the graph.
pipeline.replace_all(DataflowRunner._NON_PORTABLE_PTRANSFORM_OVERRIDES)
- # Always upload graph out-of-band when explicitly using runner v2 with
- # use_portable_job_submission to avoid irrelevant large graph limits.
- if (apiclient._use_unified_worker(debug_options) and
- debug_options.lookup_experiment('use_portable_job_submission') and
- not debug_options.lookup_experiment('upload_graph')):
- debug_options.add_experiment("upload_graph")
-
# Add setup_options for all the BeamPlugin imports
setup_options = options.view_as(SetupOptions)
plugins = BeamPlugin.get_all_plugin_paths()
