See 
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/1386/display/redirect?page=changes>

Changes:

[aljoscha.krettek] [BEAM-1116] Support for new Timer API in Flink Batch runner

------------------------------------------
[...truncated 1.35 MB...]
  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_07_50_51-8823627722229561192_0000015a856e6cd5: 
2017-02-28T15:54:50.965Z: JOB_MESSAGE_ERROR: (7681d82e16d6c367): 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_07_50_51-8823627722229561192_0000015a856e7934: 
2017-02-28T15:54:54.132Z: JOB_MESSAGE_ERROR: (7681d82e16d6c424): 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_07_50_51-8823627722229561192_0000015a856e8571: 
2017-02-28T15:54:57.265Z: JOB_MESSAGE_ERROR: (7681d82e16d6c4e1): 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_07_50_51-8823627722229561192_0000015a856e91be: 
2017-02-28T15:55:00.414Z: JOB_MESSAGE_ERROR: (7681d82e16d6c59e): 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_07_50_51-8823627722229561192_0000015a856e9243: 
2017-02-28T15:55:00.547Z: JOB_MESSAGE_DEBUG: (f2592ab82148557): Executing 
failure step failure12
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856e9245: 
2017-02-28T15:55:00.549Z: JOB_MESSAGE_ERROR: (f2592ab82148921): Workflow 
failed. Causes: (f2592ab821489f9): 
S03:compute+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write
 failed.
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856e9337: 
2017-02-28T15:55:00.791Z: JOB_MESSAGE_DETAILED: (a5e5d820d484b44e): Cleaning up.
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856e933b: 
2017-02-28T15:55:00.795Z: JOB_MESSAGE_DEBUG: (a5e5d820d484bebc): Starting 
worker pool teardown.
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856e933d: 
2017-02-28T15:55:00.797Z: JOB_MESSAGE_BASIC: (a5e5d820d484b92a): Stopping 
worker pool...
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856f7da3: 
2017-02-28T15:56:00.803Z: JOB_MESSAGE_BASIC: (a5e5d820d484b8cf): Worker pool 
stopped.
root: INFO: 2017-02-28_07_50_51-8823627722229561192_0000015a856f7dbc: 
2017-02-28T15:56:00.828Z: JOB_MESSAGE_DEBUG: (a5e5d820d484b819): Tearing down 
pending resources...
root: INFO: Job 2017-02-28_07_50_51-8823627722229561192 is in state 
JOB_STATE_FAILED
--------------------- >> end captured logging << ---------------------

----------------------------------------------------------------------
Ran 14 tests in 4284.967s

FAILED (errors=13)
Build step 'Execute shell' marked build as failure

Reply via email to