[
https://issues.apache.org/jira/browse/BEAM-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867884#comment-16867884
]
Valentyn Tymofieiev commented on BEAM-7548:
-------------------------------------------
test_approximate_unique_global_by_sample_size is also flaky:
{noformat}
08:00:40 ======================================================================
08:00:40 ERROR: test_approximate_unique_global_by_sample_size
(apache_beam.transforms.stats_test.ApproximateUniqueTest)
08:00:40 ----------------------------------------------------------------------
08:00:40 Traceback (most recent call last):
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/transforms/stats_test.py",
line 177, in test_approximate_unique_global_by_sample_size
08:00:40 pipeline.run()
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/testing/test_pipeline.py",
line 107, in run
08:00:40 else test_runner_api))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/pipeline.py",
line 406, in run
08:00:40 self._options).run(False)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/pipeline.py",
line 419, in run
08:00:40 return self.runner.run_pipeline(self, self._options)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/direct/direct_runner.py",
line 128, in run_pipeline
08:00:40 return runner.run_pipeline(pipeline, options)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 294, in run_pipeline
08:00:40 default_environment=self._default_environment))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 301, in run_via_runner_api
08:00:40 return self.run_stages(stage_context, stages)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 383, in run_stages
08:00:40 stage_context.safe_coders)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 655, in _run_stage
08:00:40 result, splits = bundle_manager.process_bundle(data_input,
data_output)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 1471, in process_bundle
08:00:40 result_future =
self._controller.control_handler.push(process_bundle_req)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 990, in push
08:00:40 response = self.worker.do_instruction(request)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py",
line 342, in do_instruction
08:00:40 request.instruction_id)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py",
line 368, in process_bundle
08:00:40 bundle_processor.process_bundle(instruction_id))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py",
line 593, in process_bundle
08:00:40 data.ptransform_id].process_encoded(data.data)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py",
line 143, in process_encoded
08:00:40 self.output(decoded_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 256, in output
08:00:40 cython.cast(Receiver,
self.receivers[output_index]).receive(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 143, in receive
08:00:40 self.consumer.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 594, in process
08:00:40 delayed_application = self.dofn_receiver.receive(o)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 778, in receive
08:00:40 self.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 784, in process
08:00:40 self._reraise_augmented(exn)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 782, in process
08:00:40 return self.do_fn_invoker.invoke_process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 595, in invoke_process
08:00:40 windowed_value, additional_args, additional_kwargs,
output_processor)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 666, in _invoke_process_per_window
08:00:40 windowed_value, self.process_method(*args_for_process))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 921, in process_outputs
08:00:40 self.main_receivers.receive(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 143, in receive
08:00:40 self.consumer.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 594, in process
08:00:40 delayed_application = self.dofn_receiver.receive(o)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 778, in receive
08:00:40 self.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 784, in process
08:00:40 self._reraise_augmented(exn)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 782, in process
08:00:40 return self.do_fn_invoker.invoke_process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 454, in invoke_process
08:00:40 windowed_value, self.process_method(windowed_value.value))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 921, in process_outputs
08:00:40 self.main_receivers.receive(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 143, in receive
08:00:40 self.consumer.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
line 594, in process
08:00:40 delayed_application = self.dofn_receiver.receive(o)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 778, in receive
08:00:40 self.process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 784, in process
08:00:40 self._reraise_augmented(exn)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 851, in _reraise_augmented
08:00:40 raise_with_traceback(new_exn)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/target/.tox-py37-gcp/py37-gcp/lib/python3.7/site-packages/future/utils/__init__.py",
line 419, in raise_with_traceback
08:00:40 raise exc.with_traceback(traceback)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 782, in process
08:00:40 return self.do_fn_invoker.invoke_process(windowed_value)
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/runners/common.py",
line 454, in invoke_process
08:00:40 windowed_value, self.process_method(windowed_value.value))
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/transforms/core.py",
line 1293, in <lambda>
08:00:40 wrapper = lambda x: [fn(x)]
08:00:40 File
"/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Phrase/src/sdks/python/test-suites/tox/py37/build/srcs/sdks/python/apache_beam/testing/util.py",
line 130, in _equal
08:00:40 'Failed assert: %r == %r' % (sorted_expected, sorted_actual))
08:00:40 apache_beam.testing.util.BeamAssertException: Failed assert: [True] ==
[False] [while running 'assert:global_by_size/Match']
{noformat}
> test_approximate_unique_global_by_error is flaky
> ------------------------------------------------
>
> Key: BEAM-7548
> URL: https://issues.apache.org/jira/browse/BEAM-7548
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core, test-failures
> Reporter: Valentyn Tymofieiev
> Assignee: Hannah Jiang
> Priority: Major
>
> The error happened on Jenkins in Python 3.5 suite, which currently uses
> Python 3.5.2 interpreter:
> {noformat}
> 11:57:47
> ======================================================================
> 11:57:47 ERROR: test_approximate_unique_global_by_error
> (apache_beam.transforms.stats_test.ApproximateUniqueTest)
> 11:57:47
> ----------------------------------------------------------------------
> 11:57:47 Traceback (most recent call last):
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/transforms/stats_test.py",
> line 236, in test_approximate_unique_global_by_error
> 11:57:47 pipeline.run()
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/testing/test_pipeline.py",
> line 107, in run
> 11:57:47 else test_runner_api))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/pipeline.py",
> line 406, in run
> 11:57:47 self._options).run(False)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/pipeline.py",
> line 419, in run
> 11:57:47 return self.runner.run_pipeline(self, self._options)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/direct/direct_runner.py",
> line 128, in run_pipeline
> 11:57:47 return runner.run_pipeline(pipeline, options)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 289, in run_pipeline
> 11:57:47 default_environment=self._default_environment))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 293, in run_via_runner_api
> 11:57:47 return self.run_stages(*self.create_stages(pipeline_proto))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 369, in run_stages
> 11:57:47 stage_context.safe_coders)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 531, in run_stage
> 11:57:47 data_input, data_output)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 1235, in process_bundle
> 11:57:47 result_future =
> self._controller.control_handler.push(process_bundle)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
> line 851, in push
> 11:57:47 response = self.worker.do_instruction(request)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py",
> line 342, in do_instruction
> 11:57:47 request.instruction_id)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py",
> line 368, in process_bundle
> 11:57:47 bundle_processor.process_bundle(instruction_id))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py",
> line 595, in process_bundle
> 11:57:47 data.ptransform_id].process_encoded(data.data)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py",
> line 143, in process_encoded
> 11:57:47 self.output(decoded_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 256, in output
> 11:57:47 cython.cast(Receiver,
> self.receivers[output_index]).receive(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 143, in receive
> 11:57:47 self.consumer.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 594, in process
> 11:57:47 delayed_application = self.dofn_receiver.receive(o)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 778, in receive
> 11:57:47 self.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 784, in process
> 11:57:47 self._reraise_augmented(exn)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 782, in process
> 11:57:47 return self.do_fn_invoker.invoke_process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 595, in invoke_process
> 11:57:47 windowed_value, additional_args, additional_kwargs,
> output_processor)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 666, in _invoke_process_per_window
> 11:57:47 windowed_value, self.process_method(*args_for_process))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 921, in process_outputs
> 11:57:47 self.main_receivers.receive(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 143, in receive
> 11:57:47 self.consumer.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 594, in process
> 11:57:47 delayed_application = self.dofn_receiver.receive(o)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 778, in receive
> 11:57:47 self.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 784, in process
> 11:57:47 self._reraise_augmented(exn)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 782, in process
> 11:57:47 return self.do_fn_invoker.invoke_process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 454, in invoke_process
> 11:57:47 windowed_value, self.process_method(windowed_value.value))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 921, in process_outputs
> 11:57:47 self.main_receivers.receive(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 143, in receive
> 11:57:47 self.consumer.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/worker/operations.py",
> line 594, in process
> 11:57:47 delayed_application = self.dofn_receiver.receive(o)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 778, in receive
> 11:57:47 self.process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 784, in process
> 11:57:47 self._reraise_augmented(exn)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 851, in _reraise_augmented
> 11:57:47 raise_with_traceback(new_exn)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/target/.tox-py35/py35/lib/python3.5/site-packages/future/utils/__init__.py",
> line 419, in raise_with_traceback
> 11:57:47 raise exc.with_traceback(traceback)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 782, in process
> 11:57:47 return self.do_fn_invoker.invoke_process(windowed_value)
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/runners/common.py",
> line 454, in invoke_process
> 11:57:47 windowed_value, self.process_method(windowed_value.value))
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/transforms/core.py",
> line 1293, in <lambda>
> 11:57:47 wrapper = lambda x: [fn(x)]
> 11:57:47 File
> "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_Commit/src/sdks/python/test-suites/tox/py35/build/srcs/sdks/python/apache_beam/testing/util.py",
> line 130, in _equal
> 11:57:47 'Failed assert: %r == %r' % (sorted_expected, sorted_actual))
> 11:57:47 apache_beam.testing.util.BeamAssertException: Failed assert: [True]
> == [False] [while running 'assert:global_by_error/Match']
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
