[
https://issues.apache.org/jira/browse/BEAM-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531279#comment-17531279
]
Brian Hulette commented on BEAM-13783:
--------------------------------------
Thanks [~Ryan.Thompson] - FYI for test/infra tickets like this we usually mark
them with fix version N/A, since they're not relevant for release notes.
> apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest.test_combine
> is flaky
> -------------------------------------------------------------------------------------------------
>
> Key: BEAM-13783
> URL: https://issues.apache.org/jira/browse/BEAM-13783
> Project: Beam
> Issue Type: Bug
> Components: test-failures
> Reporter: Brian Hulette
> Priority: P2
> Labels: flake
> Fix For: Not applicable
>
>
> First failure I can find is
> https://ci-beam.apache.org/job/beam_PreCommit_Python_Cron/5214/
> {code}
> self =
> <apache_beam.transforms.combinefn_lifecycle_test.LocalCombineFnLifecycleTest_0
> testMethod=test_combine>
> def test_combine(self):
> > run_combine(TestPipeline(runner=self.runner()))
> apache_beam/transforms/combinefn_lifecycle_test.py:88:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> apache_beam/transforms/combinefn_lifecycle_pipeline.py:124: in run_combine
> assert_that(pcoll, equal_to([(expected_result, expected_result)]))
> apache_beam/pipeline.py:596: in __exit__
> self.result = self.run()
> apache_beam/testing/test_pipeline.py:116: in run
> state = result.wait_until_finish()
> apache_beam/runners/direct/direct_runner.py:588: in wait_until_finish
> self._executor.await_completion()
> apache_beam/runners/direct/executor.py:432: in await_completion
> self._executor.await_completion()
> apache_beam/runners/direct/executor.py:480: in await_completion
> raise update.exception
> apache_beam/runners/direct/executor.py:375: in call
> finish_state)
> apache_beam/runners/direct/executor.py:404: in attempt_call
> evaluator.start_bundle()
> apache_beam/runners/direct/transform_evaluator.py:865: in start_bundle
> self.runner.setup()
> apache_beam/runners/common.py:1245: in setup
> self._invoke_lifecycle_method(self.do_fn_invoker.invoke_setup)
> apache_beam/runners/common.py:1241: in _invoke_lifecycle_method
> self._reraise_augmented(exn)
> apache_beam/runners/common.py:1281: in _reraise_augmented
> raise new_exn.with_traceback(tb)
> apache_beam/runners/common.py:1239: in _invoke_lifecycle_method
> lifecycle_method()
> apache_beam/runners/common.py:465: in invoke_setup
> self.signature.setup_lifecycle_method.method_value()
> apache_beam/runners/direct/helper_transforms.py:101: in setup
> self._combine_fn.setup()
> apache_beam/typehints/typecheck.py:205: in setup
> self._combinefn.setup(*args, **kwargs)
> apache_beam/transforms/combiners.py:824: in setup
> self.fn.setup(*self.args, **self.kwargs)
> apache_beam/transforms/combiners.py:646: in setup
> c.setup(*args, **kwargs)
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> self =
> <apache_beam.transforms.combinefn_lifecycle_pipeline.CallSequenceEnforcingCombineFn
> object at 0x7fd4428e9358>
> args = (None,), kwargs = {}
> def setup(self, *args, **kwargs):
> > assert not self._setup_called, 'setup should not be called twice'
> E AssertionError: setup should not be called twice [while running
> 'Do/CombinePerKey/CombinePerKey(PreCombineFn)/ParDo(FinishCombine)']
> {code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
