tvalentyn commented on pull request #13048:
URL: https://github.com/apache/beam/pull/13048#issuecomment-722025568
I am seeing an error in one of the tests that we run internally with this
change:
```
test_global_fanout (apache_beam.transforms.combiners_test.CombineTest) ...
ERROR
======================================================================
ERROR: test_global_fanout (apache_beam.transforms.combiners_test.CombineTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/transforms/combiners_test.py",
line 544, in test_global_fanout
assert_that(result, equal_to([49.5]))
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 568, in __exit__
self.result = self.run()
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/testing/test_pipeline.py",
line 112, in run
False if self.not_use_test_runner_api else test_runner_api))
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 518, in run
allow_proto_holders=True).run(False)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 547, in run
return self.runner.run_pipeline(self, self._options)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/runners/dataflow/test_dataflow_runner.py",
line 57, in run_pipeline
self).run_pipeline(pipeline, options)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/runners/dataflow/dataflow_runner.py",
line 495, in run_pipeline
self._check_for_unsupported_features_on_non_portable_worker(pipeline)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/runners/dataflow/dataflow_runner.py",
line 467, in _check_for_unsupported_features_on_non_portable_worker
pipeline.visit(self.combinefn_visitor())
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 594, in visit
self._root_transform().visit(visitor, self, visited)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 1085, in visit
part.visit(visitor, pipeline, visited)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 1085, in visit
part.visit(visitor, pipeline, visited)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 1085, in visit
part.visit(visitor, pipeline, visited)
[Previous line repeated 2 more times]
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/pipeline.py",
line 1088, in visit
visitor.visit_transform(self)
File
"/build/work/12791c230bd5926c2b95fef2c4fb1814e38e/google3/runfiles/google3/third_party/py/apache_beam/runners/dataflow/dataflow_runner.py",
line 430, in visit_transform
'CombineFn.setup and CombineFn.teardown are '
ValueError: CombineFn.setup and CombineFn.teardown are not supported with
non-portable Dataflow runner. Please use Dataflow Runner V2 instead.
----------------------------------------------------------------------
Ran 1 test in 1.216s
FAILED (errors=1)
```
I wonder if this broke ValidatesRunner tests on RunnerV1.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
