beam-builds mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: beam_PreCommit_Python_Cron #1525
Date Mon, 08 Jul 2019 12:46:33 GMT
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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org


Mime
View raw message