See
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/1390/display/redirect>
------------------------------------------
[...truncated 1.30 MB...]
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec4d:
2017-02-28T22:08:56.909Z: JOB_MESSAGE_DEBUG: (958b7212b5f9e82): Adding workflow
start and stop steps.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec4f:
2017-02-28T22:08:56.911Z: JOB_MESSAGE_DEBUG: (958b7212b5f9964): Assigning stage
ids.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec6e:
2017-02-28T22:08:56.942Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edc175): Executing wait
step start13
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec75:
2017-02-28T22:08:56.949Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edcc3b): Executing
operation start
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec77:
2017-02-28T22:08:56.951Z: JOB_MESSAGE_DEBUG: (cad2f82e97c2ebb0): Executing
operation side
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec7e:
2017-02-28T22:08:56.958Z: JOB_MESSAGE_DEBUG: (cad2f82e97c2e1af): Value
"start.out" materialized.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec81:
2017-02-28T22:08:56.961Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edc622): Value
"side.out" materialized.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec88:
2017-02-28T22:08:56.968Z: JOB_MESSAGE_BASIC: S01: (4baaac7ad3edc009): Executing
operation ViewAsIterable(side.None)/CreatePCollectionView
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec92:
2017-02-28T22:08:56.978Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edc832): Value
"ViewAsIterable(side.None)/CreatePCollectionView.out" materialized.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ec99:
2017-02-28T22:08:56.985Z: JOB_MESSAGE_BASIC: S02: (4baaac7ad3edc13a): Executing
operation assert_that/Group/Create
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ed64:
2017-02-28T22:08:57.188Z: JOB_MESSAGE_DEBUG: (8ba93fd93961f4cb): Starting
worker pool setup.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ed66:
2017-02-28T22:08:57.190Z: JOB_MESSAGE_BASIC: (8ba93fd93961f789): Starting 1
workers...
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ed71:
2017-02-28T22:08:57.201Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edc6c6): Value
"assert_that/Group/Session" materialized.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c4ed79:
2017-02-28T22:08:57.209Z: JOB_MESSAGE_BASIC: S03: (4baaac7ad3edc0ad): Executing
operation
compute+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c68631:
2017-02-28T22:10:41.841Z: JOB_MESSAGE_DETAILED: (3e171a393d2560f): Workers have
started successfully.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c91826:
2017-02-28T22:13:30.278Z: JOB_MESSAGE_ERROR: (561a3cc8e4257de): Traceback (most
recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 544, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 971, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30533)
with op.scoped_metrics_container:
File "dataflow_worker/executor.py", line 972, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30481)
op.start()
File "dataflow_worker/executor.py", line 207, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8758)
def start(self):
File "dataflow_worker/executor.py", line 208, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8663)
with self.scoped_start_state:
File "dataflow_worker/executor.py", line 213, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8579)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 223, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8524)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 151, in
dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:6317)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 84, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:4021)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 544, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18474)
with self.scoped_process_state:
File "dataflow_worker/executor.py", line 545, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18428)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 195, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:5142)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7201)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 279, in
apache_beam.runners.common.DoFnRunner.reraise_augmented
(apache_beam/runners/common.c:7590)
raise type(exn), args, sys.exc_info()[2]
File "apache_beam/runners/common.py", line 265, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7112)
self._dofn_invoker(element)
File "apache_beam/runners/common.py", line 232, in
apache_beam.runners.common.DoFnRunner._dofn_invoker
(apache_beam/runners/common.c:6131)
self._dofn_per_window_invoker(element)
File "apache_beam/runners/common.py", line 218, in
apache_beam.runners.common.DoFnRunner._dofn_per_window_invoker
(apache_beam/runners/common.c:5877)
self._process_outputs(element, self.dofn_process(*args))
File "apache_beam/runners/common.py", line 326, in
apache_beam.runners.common.DoFnRunner._process_outputs
(apache_beam/runners/common.c:8563)
self.main_receivers.receive(windowed_value)
File "dataflow_worker/executor.py", line 82, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3987)
self.update_counters_start(windowed_value)
File "dataflow_worker/executor.py", line 88, in
dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:4207)
self.opcounter.update_from(windowed_value)
File "dataflow_worker/opcounters.py", line 57, in
dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2396)
self.do_sample(windowed_value)
File "dataflow_worker/opcounters.py", line 75, in
dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:3017)
self.coder_impl.get_estimated_size_and_observables(windowed_value))
File "apache_beam/coders/coder_impl.py", line 695, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22894)
def get_estimated_size_and_observables(self, value, nested=False):
File "apache_beam/coders/coder_impl.py", line 704, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22613)
self._value_coder.get_estimated_size_and_observables(
File "apache_beam/coders/coder_impl.py", line 247, in
apache_beam.coders.coder_impl.FastPrimitivesCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:9564)
out = ByteCountingOutputStream()
File "apache_beam/coders/stream.pyx", line 28, in
apache_beam.coders.stream.OutputStream.__cinit__
(apache_beam/coders/stream.c:1241)
self.buffer_size = 1024
AttributeError: 'apache_beam.coders.stream.ByteCountingOutputStream' object has
no attribute 'buffer_size' [while running 'compute']
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c924dd:
2017-02-28T22:13:33.533Z: JOB_MESSAGE_ERROR: (561a3cc8e4250e9): Traceback (most
recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 544, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 971, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30533)
with op.scoped_metrics_container:
File "dataflow_worker/executor.py", line 972, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30481)
op.start()
File "dataflow_worker/executor.py", line 207, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8758)
def start(self):
File "dataflow_worker/executor.py", line 208, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8663)
with self.scoped_start_state:
File "dataflow_worker/executor.py", line 213, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8579)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 223, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8524)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 151, in
dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:6317)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 84, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:4021)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 544, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18474)
with self.scoped_process_state:
File "dataflow_worker/executor.py", line 545, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18428)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 195, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:5142)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7201)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 279, in
apache_beam.runners.common.DoFnRunner.reraise_augmented
(apache_beam/runners/common.c:7590)
raise type(exn), args, sys.exc_info()[2]
File "apache_beam/runners/common.py", line 265, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7112)
self._dofn_invoker(element)
File "apache_beam/runners/common.py", line 232, in
apache_beam.runners.common.DoFnRunner._dofn_invoker
(apache_beam/runners/common.c:6131)
self._dofn_per_window_invoker(element)
File "apache_beam/runners/common.py", line 218, in
apache_beam.runners.common.DoFnRunner._dofn_per_window_invoker
(apache_beam/runners/common.c:5877)
self._process_outputs(element, self.dofn_process(*args))
File "apache_beam/runners/common.py", line 326, in
apache_beam.runners.common.DoFnRunner._process_outputs
(apache_beam/runners/common.c:8563)
self.main_receivers.receive(windowed_value)
File "dataflow_worker/executor.py", line 82, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3987)
self.update_counters_start(windowed_value)
File "dataflow_worker/executor.py", line 88, in
dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:4207)
self.opcounter.update_from(windowed_value)
File "dataflow_worker/opcounters.py", line 57, in
dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2396)
self.do_sample(windowed_value)
File "dataflow_worker/opcounters.py", line 75, in
dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:3017)
self.coder_impl.get_estimated_size_and_observables(windowed_value))
File "apache_beam/coders/coder_impl.py", line 695, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22894)
def get_estimated_size_and_observables(self, value, nested=False):
File "apache_beam/coders/coder_impl.py", line 704, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22613)
self._value_coder.get_estimated_size_and_observables(
File "apache_beam/coders/coder_impl.py", line 247, in
apache_beam.coders.coder_impl.FastPrimitivesCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:9564)
out = ByteCountingOutputStream()
File "apache_beam/coders/stream.pyx", line 28, in
apache_beam.coders.stream.OutputStream.__cinit__
(apache_beam/coders/stream.c:1241)
self.buffer_size = 1024
AttributeError: 'apache_beam.coders.stream.ByteCountingOutputStream' object has
no attribute 'buffer_size' [while running 'compute']
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c9316a:
2017-02-28T22:13:36.746Z: JOB_MESSAGE_ERROR: (561a3cc8e4259f4): Traceback (most
recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 544, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 971, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30533)
with op.scoped_metrics_container:
File "dataflow_worker/executor.py", line 972, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30481)
op.start()
File "dataflow_worker/executor.py", line 207, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8758)
def start(self):
File "dataflow_worker/executor.py", line 208, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8663)
with self.scoped_start_state:
File "dataflow_worker/executor.py", line 213, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8579)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 223, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8524)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 151, in
dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:6317)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 84, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:4021)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 544, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18474)
with self.scoped_process_state:
File "dataflow_worker/executor.py", line 545, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18428)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 195, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:5142)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7201)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 279, in
apache_beam.runners.common.DoFnRunner.reraise_augmented
(apache_beam/runners/common.c:7590)
raise type(exn), args, sys.exc_info()[2]
File "apache_beam/runners/common.py", line 265, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7112)
self._dofn_invoker(element)
File "apache_beam/runners/common.py", line 232, in
apache_beam.runners.common.DoFnRunner._dofn_invoker
(apache_beam/runners/common.c:6131)
self._dofn_per_window_invoker(element)
File "apache_beam/runners/common.py", line 218, in
apache_beam.runners.common.DoFnRunner._dofn_per_window_invoker
(apache_beam/runners/common.c:5877)
self._process_outputs(element, self.dofn_process(*args))
File "apache_beam/runners/common.py", line 326, in
apache_beam.runners.common.DoFnRunner._process_outputs
(apache_beam/runners/common.c:8563)
self.main_receivers.receive(windowed_value)
File "dataflow_worker/executor.py", line 82, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3987)
self.update_counters_start(windowed_value)
File "dataflow_worker/executor.py", line 88, in
dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:4207)
self.opcounter.update_from(windowed_value)
File "dataflow_worker/opcounters.py", line 57, in
dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2396)
self.do_sample(windowed_value)
File "dataflow_worker/opcounters.py", line 75, in
dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:3017)
self.coder_impl.get_estimated_size_and_observables(windowed_value))
File "apache_beam/coders/coder_impl.py", line 695, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22894)
def get_estimated_size_and_observables(self, value, nested=False):
File "apache_beam/coders/coder_impl.py", line 704, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22613)
self._value_coder.get_estimated_size_and_observables(
File "apache_beam/coders/coder_impl.py", line 247, in
apache_beam.coders.coder_impl.FastPrimitivesCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:9564)
out = ByteCountingOutputStream()
File "apache_beam/coders/stream.pyx", line 28, in
apache_beam.coders.stream.OutputStream.__cinit__
(apache_beam/coders/stream.c:1241)
self.buffer_size = 1024
AttributeError: 'apache_beam.coders.stream.ByteCountingOutputStream' object has
no attribute 'buffer_size' [while running 'compute']
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c93df1:
2017-02-28T22:13:39.953Z: JOB_MESSAGE_ERROR: (561a3cc8e4252ff): Traceback (most
recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 544, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 971, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30533)
with op.scoped_metrics_container:
File "dataflow_worker/executor.py", line 972, in
dataflow_worker.executor.MapTaskExecutor.execute
(dataflow_worker/executor.c:30481)
op.start()
File "dataflow_worker/executor.py", line 207, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8758)
def start(self):
File "dataflow_worker/executor.py", line 208, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8663)
with self.scoped_start_state:
File "dataflow_worker/executor.py", line 213, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8579)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 223, in
dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:8524)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 151, in
dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:6317)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 84, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:4021)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 544, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18474)
with self.scoped_process_state:
File "dataflow_worker/executor.py", line 545, in
dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:18428)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 195, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:5142)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7201)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 279, in
apache_beam.runners.common.DoFnRunner.reraise_augmented
(apache_beam/runners/common.c:7590)
raise type(exn), args, sys.exc_info()[2]
File "apache_beam/runners/common.py", line 265, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:7112)
self._dofn_invoker(element)
File "apache_beam/runners/common.py", line 232, in
apache_beam.runners.common.DoFnRunner._dofn_invoker
(apache_beam/runners/common.c:6131)
self._dofn_per_window_invoker(element)
File "apache_beam/runners/common.py", line 218, in
apache_beam.runners.common.DoFnRunner._dofn_per_window_invoker
(apache_beam/runners/common.c:5877)
self._process_outputs(element, self.dofn_process(*args))
File "apache_beam/runners/common.py", line 326, in
apache_beam.runners.common.DoFnRunner._process_outputs
(apache_beam/runners/common.c:8563)
self.main_receivers.receive(windowed_value)
File "dataflow_worker/executor.py", line 82, in
dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3987)
self.update_counters_start(windowed_value)
File "dataflow_worker/executor.py", line 88, in
dataflow_worker.executor.ConsumerSet.update_counters_start
(dataflow_worker/executor.c:4207)
self.opcounter.update_from(windowed_value)
File "dataflow_worker/opcounters.py", line 57, in
dataflow_worker.opcounters.OperationCounters.update_from
(dataflow_worker/opcounters.c:2396)
self.do_sample(windowed_value)
File "dataflow_worker/opcounters.py", line 75, in
dataflow_worker.opcounters.OperationCounters.do_sample
(dataflow_worker/opcounters.c:3017)
self.coder_impl.get_estimated_size_and_observables(windowed_value))
File "apache_beam/coders/coder_impl.py", line 695, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22894)
def get_estimated_size_and_observables(self, value, nested=False):
File "apache_beam/coders/coder_impl.py", line 704, in
apache_beam.coders.coder_impl.WindowedValueCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:22613)
self._value_coder.get_estimated_size_and_observables(
File "apache_beam/coders/coder_impl.py", line 247, in
apache_beam.coders.coder_impl.FastPrimitivesCoderImpl.get_estimated_size_and_observables
(apache_beam/coders/coder_impl.c:9564)
out = ByteCountingOutputStream()
File "apache_beam/coders/stream.pyx", line 28, in
apache_beam.coders.stream.OutputStream.__cinit__
(apache_beam/coders/stream.c:1241)
self.buffer_size = 1024
AttributeError: 'apache_beam.coders.stream.ByteCountingOutputStream' object has
no attribute 'buffer_size' [while running 'compute']
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c94afc:
2017-02-28T22:13:43.292Z: JOB_MESSAGE_DEBUG: (4baaac7ad3edc1de): Executing
failure step failure12
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c94afe:
2017-02-28T22:13:43.294Z: JOB_MESSAGE_ERROR: (4baaac7ad3edc020): Workflow
failed. Causes: (4baaac7ad3edc718):
S03:compute+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write
failed.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c94bba:
2017-02-28T22:13:43.482Z: JOB_MESSAGE_DEBUG: (958b7212b5f9021): Starting worker
pool teardown.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86c94bbc:
2017-02-28T22:13:43.484Z: JOB_MESSAGE_BASIC: (958b7212b5f9b03): Stopping worker
pool...
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86ca5d32:
2017-02-28T22:14:53.490Z: JOB_MESSAGE_BASIC: (958b7212b5f9b56): Worker pool
stopped.
root: INFO: 2017-02-28_14_08_54-8016205494795483092_0000015a86ca5d4e:
2017-02-28T22:14:53.518Z: JOB_MESSAGE_DEBUG: (958b7212b5f9bfc): Tearing down
pending resources...
root: INFO: Job 2017-02-28_14_08_54-8016205494795483092 is in state
JOB_STATE_FAILED
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 14 tests in 4275.768s
FAILED (errors=13)
Build step 'Execute shell' marked build as failure
