beam-commits 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_PostCommit_PythonVerify #630
Date Tue, 01 Nov 2016 05:22:39 GMT
See <https://builds.apache.org/job/beam_PostCommit_PythonVerify/630/changes>

Changes:

[robertwb] Move Timestamp and related classes into apache_beam/utils.

[robertwb] Remove fake Timestamp and WindowedValue hacks.

------------------------------------------
[...truncated 6723 lines...]
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e557f2a: 2016-11-01T05:21:09.418Z:
JOB_MESSAGE_ERROR: (2794773e6e4166e6): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5580f7: 2016-11-01T05:21:09.879Z:
JOB_MESSAGE_ERROR: (2794773e6e416d82): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5582dc: 2016-11-01T05:21:10.364Z:
JOB_MESSAGE_ERROR: (2794773e6e41641e): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5584e8: 2016-11-01T05:21:10.888Z:
JOB_MESSAGE_ERROR: (2794773e6e416aba): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e55867e: 2016-11-01T05:21:11.294Z:
JOB_MESSAGE_ERROR: (2794773e6e416156): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'

INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5586a7: 2016-11-01T05:21:11.335Z:
JOB_MESSAGE_DEBUG: (d9399e3799c880bc): Executing failure step failure1
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5586a9: 2016-11-01T05:21:11.337Z:
JOB_MESSAGE_ERROR: (d9399e3799c885ee): Workflow failed. Causes: (f20f1f71e79fa4c4): S07:group/Read+group/GroupByWindow+count+format+write/WriteImpl/write_bundles+write/WriteImpl/Map(<lambda
at iobase.py:755>)+write/WriteImpl/WindowInto+write/WriteImpl/GroupByKey/Reify+write/WriteImpl/GroupByKey/Write
failed.
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e5586db: 2016-11-01T05:21:11.387Z:
JOB_MESSAGE_DETAILED: (d9399e3799c88db9): Cleaning up.
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e558764: 2016-11-01T05:21:11.524Z:
JOB_MESSAGE_DEBUG: (d9399e3799c88584): Starting worker pool teardown.
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e558766: 2016-11-01T05:21:11.526Z:
JOB_MESSAGE_BASIC: (d9399e3799c88ab6): Stopping worker pool...
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e56bfee: 2016-11-01T05:22:31.534Z:
JOB_MESSAGE_BASIC: (d9399e3799c88281): Worker pool stopped.
INFO:root:2016-10-31_22_18_40-15837001721901554053_000001581e56c3ec: 2016-11-01T05:22:32.556Z:
JOB_MESSAGE_DEBUG: (d9399e3799c88f7e): Tearing down pending resources...
INFO:root:Job 2016-10-31_22_18_40-15837001721901554053 is in state JOB_STATE_FAILED
Traceback (most recent call last):
  File "/usr/lib/python2.7/runpy.py", line 162, in _run_module_as_main
    "__main__", fname, loader, pkg_name)
  File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
    exec code in run_globals
  File "<https://builds.apache.org/job/beam_PostCommit_PythonVerify/ws/sdks/python/apache_beam/examples/wordcount.py",>
line 107, in <module>
    run()
  File "<https://builds.apache.org/job/beam_PostCommit_PythonVerify/ws/sdks/python/apache_beam/examples/wordcount.py",>
line 98, in run
    result = p.run()
  File "apache_beam/pipeline.py", line 159, in run
    return self.runner.run(self)
  File "apache_beam/runners/dataflow_runner.py", line 189, in run
    % getattr(self, 'last_error_msg', None), self.result)
apache_beam.runners.dataflow_runner.DataflowRuntimeException: Dataflow pipeline failed:
(2794773e6e416156): Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514,
in do_work
    work_executor.execute()
  File "dataflow_worker/executor.py", line 908, in dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:24500)
    op.start()
  File "dataflow_worker/executor.py", line 279, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9332)
    def start(self):
  File "dataflow_worker/executor.py", line 287, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9239)
    with self.shuffle_source.reader() as reader:
  File "dataflow_worker/executor.py", line 291, in dataflow_worker.executor.GroupedShuffleReadOperation.start
(dataflow_worker/executor.c:9184)
    self.output(windowed_value)
  File "dataflow_worker/executor.py", line 142, in dataflow_worker.executor.Operation.output
(dataflow_worker/executor.c:5252)
    cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
  File "dataflow_worker/executor.py", line 87, in dataflow_worker.executor.ConsumerSet.receive
(dataflow_worker/executor.c:3456)
    self.update_counters_start(windowed_value)
  File "dataflow_worker/executor.py", line 93, in dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:3655)
    self.opcounter.update_from(windowed_value)
  File "dataflow_worker/opcounters.py", line 57, in dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2131)
    self.do_sample(windowed_value)
  File "dataflow_worker/opcounters.py", line 71, in dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:2685)
    self.coder_impl.get_estimated_size_and_observables(windowed_value))
  File "apache_beam/coders/coder_impl.py", line 524, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:17216)
    def get_estimated_size_and_observables(self, value, nested=False):
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 429, in apache_beam.coders.coder_impl.AbstractComponentCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:13931)
    c.get_estimated_size_and_observables(values[i], nested=True))
  File "apache_beam/coders/coder_impl.py", line 529, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16951)
    self._value_coder.get_estimated_size_and_observables(
  File "apache_beam/coders/coder_impl.py", line 530, in apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:16939)
    value.value, nested=True))
AttributeError: 'ShuffleKeyValuesIterable' object has no attribute 'value'


# Grep will exit with status 1 if success message was not found.
echo ">>> CHECKING JOB SUCCESS"
>>> CHECKING JOB SUCCESS
grep JOB_STATE_DONE job_output
Build step 'Execute shell' marked build as failure

Mime
View raw message