See <https://builds.apache.org/job/beam_PreCommit_Python_Cron/1525/display/redirect>
------------------------------------------ [...truncated 4.93 MB...] root: DEBUG: finish <DoOperation named.even/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <FlattenOperation named.even/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.even/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.even/Group/Flatten/Write/0 > root: DEBUG: start <DataOutputOperation named.even/Group/Flatten/Write/0 > root: DEBUG: start <FlattenOperation named.even/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.even/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <DoOperation named.even/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <ImpulseReadOperation named.even/Create/Read receivers=[SingletonConsumerSet[named.even/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.even/Create/Read/Impulse receivers=[SingletonConsumerSet[named.even/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.even/Create/Read/Impulse receivers=[SingletonConsumerSet[named.even/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: finish <ImpulseReadOperation named.even/Create/Read receivers=[SingletonConsumerSet[named.even/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <FlattenOperation named.even/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.even/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.even/Group/Flatten/Write/0 > root: DEBUG: Wait for the bundle to finish. root: DEBUG: Wait for the bundle to finish. root: INFO: Running (named.even/Group/Flatten/Read)+(named.even/Group/GroupByKey/Write) root: DEBUG: Got work control_13 root: DEBUG: Got work control_14 root: DEBUG: Got work bundle_2607 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DataOutputOperation named.even/Group/GroupByKey/Write > root: DEBUG: start <DataInputOperation named.even/Group/Flatten/Read receivers=[SingletonConsumerSet[named.even/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: Got work bundle_2608 root: DEBUG: finish <DataInputOperation named.even/Group/Flatten/Read receivers=[SingletonConsumerSet[named.even/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: Currently using 1 threads. root: DEBUG: finish <DataOutputOperation named.even/Group/GroupByKey/Write > root: DEBUG: Wait for the bundle to finish. root: DEBUG: start <DataOutputOperation named.even/Group/GroupByKey/Write > root: DEBUG: start <DataInputOperation named.even/Group/Flatten/Read receivers=[SingletonConsumerSet[named.even/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.even/Group/Flatten/Read receivers=[SingletonConsumerSet[named.even/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.even/Group/GroupByKey/Write > root: DEBUG: Wait for the bundle to finish. root: INFO: Running (named.even/Group/GroupByKey/Read)+(((ref_AppliedPTransform_named.even/Group/Map(_merge_tagged_vals_under_key)_35)+(ref_AppliedPTransform_named.even/Unkey_36))+(ref_AppliedPTransform_named.even/Match_37)) root: DEBUG: Got work control_15 root: DEBUG: Wait for the bundle to finish. root: DEBUG: Got work control_16 root: DEBUG: Got work bundle_2609 root: DEBUG: Currently using 1 threads. root: DEBUG: Wait for the bundle to finish. root: DEBUG: Got work bundle_2610 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DoOperation named.even/Match output_tags=['out'], receivers=[ConsumerSet[named.even/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: DEBUG: start <DoOperation named.even/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DoOperation named.even/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.even/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.even/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.even/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.even/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Match output_tags=['out'], receivers=[ConsumerSet[named.even/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: DEBUG: start <DoOperation named.even/Match output_tags=['out'], receivers=[ConsumerSet[named.even/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: DEBUG: start <DoOperation named.even/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DoOperation named.even/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.even/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.even/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.even/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.even/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.even/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.even/Match output_tags=['out'], receivers=[ConsumerSet[named.even/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: INFO: Running (ref_AppliedPTransform_named.odd/Create/Read_40)+(((ref_AppliedPTransform_named.odd/Group/pair_with_0_44)+(named.odd/Group/Flatten/Transcode/0))+(named.odd/Group/Flatten/Write/0)) root: DEBUG: Got work control_17 root: DEBUG: Got work control_18 root: DEBUG: Got work bundle_2611 root: DEBUG: Currently using 1 threads. root: DEBUG: Got work bundle_2612 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DataOutputOperation named.odd/Group/Flatten/Write/0 > root: DEBUG: start <FlattenOperation named.odd/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <DoOperation named.odd/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <ImpulseReadOperation named.odd/Create/Read receivers=[SingletonConsumerSet[named.odd/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.odd/Create/Read/Impulse receivers=[SingletonConsumerSet[named.odd/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: Processing [((None, (0, None)), MIN_TIMESTAMP, (GlobalWindow,), PaneInfo(first: True, last: True, timing: 3, index: 0, nonspeculative_index: 0))] in <FlattenOperation named.odd/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.odd/Create/Read/Impulse receivers=[SingletonConsumerSet[named.odd/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: finish <ImpulseReadOperation named.odd/Create/Read receivers=[SingletonConsumerSet[named.odd/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.odd/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <FlattenOperation named.odd/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.odd/Group/Flatten/Write/0 > root: DEBUG: start <DataOutputOperation named.odd/Group/Flatten/Write/0 > root: DEBUG: start <FlattenOperation named.odd/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <DoOperation named.odd/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: start <ImpulseReadOperation named.odd/Create/Read receivers=[SingletonConsumerSet[named.odd/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.odd/Create/Read/Impulse receivers=[SingletonConsumerSet[named.odd/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.odd/Create/Read/Impulse receivers=[SingletonConsumerSet[named.odd/Create/Read/Impulse.out0, coder=WindowedValueCoder[BytesCoder], len(consumers)=1]]> root: DEBUG: finish <ImpulseReadOperation named.odd/Create/Read receivers=[SingletonConsumerSet[named.odd/Create/Read.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.odd/Group/pair_with_0 output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/pair_with_0.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder, TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <FlattenOperation named.odd/Group/Flatten/Transcode/0 receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Transcode/0.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.odd/Group/Flatten/Write/0 > root: DEBUG: Wait for the bundle to finish. root: DEBUG: Wait for the bundle to finish. root: INFO: Running (named.odd/Group/Flatten/Read)+(named.odd/Group/GroupByKey/Write) root: DEBUG: Got work control_19 root: DEBUG: Got work control_20 root: DEBUG: Got work bundle_2613 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DataOutputOperation named.odd/Group/GroupByKey/Write > root: DEBUG: start <DataInputOperation named.odd/Group/Flatten/Read receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.odd/Group/Flatten/Read receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.odd/Group/GroupByKey/Write > root: DEBUG: Got work bundle_2614 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DataOutputOperation named.odd/Group/GroupByKey/Write > root: DEBUG: start <DataInputOperation named.odd/Group/Flatten/Read receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.odd/Group/Flatten/Read receivers=[SingletonConsumerSet[named.odd/Group/Flatten/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], LengthPrefixCoder[FastPrimitivesCoder]]], len(consumers)=1]]> root: DEBUG: finish <DataOutputOperation named.odd/Group/GroupByKey/Write > root: DEBUG: Wait for the bundle to finish. root: DEBUG: Wait for the bundle to finish. root: INFO: Running ((named.odd/Group/GroupByKey/Read)+(ref_AppliedPTransform_named.odd/Group/Map(_merge_tagged_vals_under_key)_51))+((ref_AppliedPTransform_named.odd/Unkey_52)+(ref_AppliedPTransform_named.odd/Match_53)) root: DEBUG: Got work control_21 root: DEBUG: Wait for the bundle to finish. root: DEBUG: Got work control_22 root: DEBUG: Got work bundle_2615 root: DEBUG: Wait for the bundle to finish. root: DEBUG: Currently using 1 threads. root: DEBUG: Got work bundle_2616 root: DEBUG: Currently using 1 threads. root: DEBUG: start <DoOperation named.odd/Match output_tags=['out'], receivers=[ConsumerSet[named.odd/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: DEBUG: start <DoOperation named.odd/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DoOperation named.odd/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.odd/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.odd/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: ERROR: Error processing instruction bundle_2615. Original traceback is Traceback (most recent call last): File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 157, in _execute response = task() File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 190, in <lambda> self._execute(lambda: worker.do_instruction(work), work) File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 342, in do_instruction request.instruction_id) File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 368, in process_bundle bundle_processor.process_bundle(instruction_id)) File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 593, in process_bundle data.ptransform_id].process_encoded(data.data) File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 143, in process_encoded self.output(decoded_value) File "apache_beam/runners/worker/operations.py", line 255, in apache_beam.runners.worker.operations.Operation.output def output(self, windowed_value, output_index=0): File "apache_beam/runners/worker/operations.py", line 256, in apache_beam.runners.worker.operations.Operation.output cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 143, in apache_beam.runners.worker.operations.SingletonConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 593, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 594, in apache_beam.runners.worker.operations.DoOperation.process delayed_application = self.dofn_receiver.receive(o) File "apache_beam/runners/common.py", line 795, in apache_beam.runners.common.DoFnRunner.receive self.process(windowed_value) File "apache_beam/runners/common.py", line 801, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 853, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise File "apache_beam/runners/common.py", line 799, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 610, in apache_beam.runners.common.PerWindowInvoker.invoke_process self._invoke_process_per_window( File "apache_beam/runners/common.py", line 682, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window output_processor.process_outputs( File "apache_beam/runners/common.py", line 899, in apache_beam.runners.common._OutputProcessor.process_outputs def process_outputs(self, windowed_input_element, results): File "apache_beam/runners/common.py", line 938, in apache_beam.runners.common._OutputProcessor.process_outputs self.main_receivers.receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 143, in apache_beam.runners.worker.operations.SingletonConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 593, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 594, in apache_beam.runners.worker.operations.DoOperation.process delayed_application = self.dofn_receiver.receive(o) File "apache_beam/runners/common.py", line 795, in apache_beam.runners.common.DoFnRunner.receive self.process(windowed_value) File "apache_beam/runners/common.py", line 801, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 853, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise File "apache_beam/runners/common.py", line 799, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 465, in apache_beam.runners.common.SimpleInvoker.invoke_process output_processor.process_outputs( File "apache_beam/runners/common.py", line 938, in apache_beam.runners.common._OutputProcessor.process_outputs self.main_receivers.receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 143, in apache_beam.runners.worker.operations.SingletonConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 593, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 594, in apache_beam.runners.worker.operations.DoOperation.process delayed_application = self.dofn_receiver.receive(o) File "apache_beam/runners/common.py", line 795, in apache_beam.runners.common.DoFnRunner.receive self.process(windowed_value) File "apache_beam/runners/common.py", line 801, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 868, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise_with_traceback(new_exn) File "apache_beam/runners/common.py", line 799, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 466, in apache_beam.runners.common.SimpleInvoker.invoke_process windowed_value, self.process_method(windowed_value.value)) File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/transforms/core.py";,> line 1296, in <lambda> wrapper = lambda x: [fn(x)] File "<https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/apache_beam/testing/util.py";,> line 130, in _equal 'Failed assert: %r == %r' % (sorted_expected, sorted_actual)) BeamAssertException: Failed assert: [1, 3] == [] [while running 'named.odd/Match'] root: DEBUG: start <DoOperation named.odd/Match output_tags=['out'], receivers=[ConsumerSet[named.odd/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: DEBUG: start <DoOperation named.odd/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DoOperation named.odd/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: start <DataInputOperation named.odd/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.odd/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DataInputOperation named.odd/Group/GroupByKey/Read receivers=[SingletonConsumerSet[named.odd/Group/GroupByKey/Read.out0, coder=WindowedValueCoder[TupleCoder[LengthPrefixCoder[FastPrimitivesCoder], IterableCoder[LengthPrefixCoder[FastPrimitivesCoder]]]], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.odd/Group/Map(_merge_tagged_vals_under_key) output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Group/Map(_merge_tagged_vals_under_key).out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.odd/Unkey output_tags=['out'], receivers=[SingletonConsumerSet[named.odd/Unkey.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=1]]> root: DEBUG: finish <DoOperation named.odd/Match output_tags=['out'], receivers=[ConsumerSet[named.odd/Match.out0, coder=WindowedValueCoder[FastPrimitivesCoder], len(consumers)=0]]> root: INFO: No more requests from control plane root: INFO: SDK Harness waiting for in-flight requests to complete root: INFO: Closing all cached grpc data channels. root: INFO: Closing all cached gRPC state handlers. root: INFO: Done consuming work. --------------------- >> end captured logging << --------------------- ---------------------------------------------------------------------- XML: <https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 2344 tests in 584.124s FAILED (SKIP=486, errors=1) ERROR: InvocationError for command <https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/target/.tox-py27-cython/py27-cython/bin/python> setup.py nosetests (exited with code 1) py27-cython run-test-post: commands[0] | <https://builds.apache.org/job/beam_PreCommit_Python_Cron/ws/src/sdks/python/build/srcs/sdks/python/scripts/run_tox_cleanup.sh> ___________________________________ summary ____________________________________ ERROR: py27-cython: commands failed > Task :sdks:python:testPy2Cython FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':sdks:python:testPy2Cython'. > Process 'command 'sh'' finished with non-zero exit value 1 * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 40m 8s 88 actionable tasks: 71 executed, 17 from cache Publishing build scan... https://gradle.com/s/3s4kurie5jaa6 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
