See
<https://builds.apache.org/job/beam_PostCommit_Python_Verify/2287/display/redirect?page=changes>
Changes:
[altay] [BEAM-1999] Remove resolved todo from value providers
[altay] Update Dataflow BATCH_ENVIRONMENT_MAJOR_VERSION to 6
------------------------------------------
[...truncated 611.48 KB...]
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 431, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11673)
raise new_exn, None, original_traceback
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 281, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
(apache_beam/runners/common.c:8626)
self._invoke_per_window(windowed_value)
File "apache_beam/runners/common.py", line 307, in
apache_beam.runners.common.PerWindowInvoker._invoke_per_window
(apache_beam/runners/common.c:9302)
windowed_value, self.process_method(*args_for_process))
File "/usr/local/lib/python2.7/dist-packages/apache_beam/io/iobase.py", line
936, in process
self.writer = self.sink.open_writer(init_result, str(uuid.uuid4()))
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/options/value_provider.py",
line 108, in _f
return fnc(self, *args, **kwargs)
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/io/filebasedsink.py", line
174, in open_writer
return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
File "/usr/lib/python2.7/posixpath.py", line 77, in join
elif path == '' or path.endswith('/'):
AttributeError: 'EmptySideInput' object has no attribute 'endswith' [while
running 'write/Write/WriteImpl/WriteBundles/Do']
root: INFO: 2017-05-22T22:12:04.261Z: JOB_MESSAGE_ERROR: (29c422a227e97533):
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 582, in do_work
work_executor.execute()
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/executor.py",
line 166, in execute
op.start()
File "dataflow_worker/shuffle_operations.py", line 48, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3561)
def start(self):
File "dataflow_worker/shuffle_operations.py", line 49, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3465)
with self.scoped_start_state:
File "dataflow_worker/shuffle_operations.py", line 62, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3380)
with self.shuffle_source.reader() as reader:
File "dataflow_worker/shuffle_operations.py", line 66, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3324)
self.output(windowed_value)
File "apache_beam/runners/worker/operations.py", line 153, in
apache_beam.runners.worker.operations.Operation.output
(apache_beam/runners/worker/operations.c:5770)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/shuffle_operations.py", line 219, in
dataflow_worker.shuffle_operations.BatchGroupAlsoByWindowsOperation.process
(dataflow_worker/shuffle_operations.c:8213)
self.output(wvalue.with_value((k, wvalue.value)))
File "apache_beam/runners/worker/operations.py", line 153, in
apache_beam.runners.worker.operations.Operation.output
(apache_beam/runners/worker/operations.c:5770)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 431, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11673)
raise new_exn, None, original_traceback
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 281, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
(apache_beam/runners/common.c:8626)
self._invoke_per_window(windowed_value)
File "apache_beam/runners/common.py", line 307, in
apache_beam.runners.common.PerWindowInvoker._invoke_per_window
(apache_beam/runners/common.c:9302)
windowed_value, self.process_method(*args_for_process))
File "/usr/local/lib/python2.7/dist-packages/apache_beam/io/iobase.py", line
936, in process
self.writer = self.sink.open_writer(init_result, str(uuid.uuid4()))
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/options/value_provider.py",
line 108, in _f
return fnc(self, *args, **kwargs)
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/io/filebasedsink.py", line
174, in open_writer
return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
File "/usr/lib/python2.7/posixpath.py", line 77, in join
elif path == '' or path.endswith('/'):
AttributeError: 'EmptySideInput' object has no attribute 'endswith' [while
running 'write/Write/WriteImpl/WriteBundles/Do']
root: INFO: 2017-05-22T22:12:06.775Z: JOB_MESSAGE_ERROR: (29c422a227e97ecc):
Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py",
line 582, in do_work
work_executor.execute()
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/executor.py",
line 166, in execute
op.start()
File "dataflow_worker/shuffle_operations.py", line 48, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3561)
def start(self):
File "dataflow_worker/shuffle_operations.py", line 49, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3465)
with self.scoped_start_state:
File "dataflow_worker/shuffle_operations.py", line 62, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3380)
with self.shuffle_source.reader() as reader:
File "dataflow_worker/shuffle_operations.py", line 66, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
(dataflow_worker/shuffle_operations.c:3324)
self.output(windowed_value)
File "apache_beam/runners/worker/operations.py", line 153, in
apache_beam.runners.worker.operations.Operation.output
(apache_beam/runners/worker/operations.c:5770)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/shuffle_operations.py", line 219, in
dataflow_worker.shuffle_operations.BatchGroupAlsoByWindowsOperation.process
(dataflow_worker/shuffle_operations.c:8213)
self.output(wvalue.with_value((k, wvalue.value)))
File "apache_beam/runners/worker/operations.py", line 153, in
apache_beam.runners.worker.operations.Operation.output
(apache_beam/runners/worker/operations.c:5770)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 415, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11363)
raise
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 189, in
apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6270)
self.output_processor.process_outputs(
File "apache_beam/runners/common.py", line 480, in
apache_beam.runners.common._OutputProcessor.process_outputs
(apache_beam/runners/common.c:12500)
self.main_receivers.receive(windowed_value)
File "apache_beam/runners/worker/operations.py", line 86, in
apache_beam.runners.worker.operations.ConsumerSet.receive
(apache_beam/runners/worker/operations.c:3622)
cython.cast(Operation, consumer).process(windowed_value)
File "apache_beam/runners/worker/operations.py", line 338, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11076)
with self.scoped_process_state:
File "apache_beam/runners/worker/operations.py", line 339, in
apache_beam.runners.worker.operations.DoOperation.process
(apache_beam/runners/worker/operations.c:11030)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 382, in
apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:10156)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 390, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10458)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 431, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11673)
raise new_exn, None, original_traceback
File "apache_beam/runners/common.py", line 388, in
apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10371)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 281, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
(apache_beam/runners/common.c:8626)
self._invoke_per_window(windowed_value)
File "apache_beam/runners/common.py", line 307, in
apache_beam.runners.common.PerWindowInvoker._invoke_per_window
(apache_beam/runners/common.c:9302)
windowed_value, self.process_method(*args_for_process))
File "/usr/local/lib/python2.7/dist-packages/apache_beam/io/iobase.py", line
936, in process
self.writer = self.sink.open_writer(init_result, str(uuid.uuid4()))
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/options/value_provider.py",
line 108, in _f
return fnc(self, *args, **kwargs)
File
"/usr/local/lib/python2.7/dist-packages/apache_beam/io/filebasedsink.py", line
174, in open_writer
return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
File "/usr/lib/python2.7/posixpath.py", line 77, in join
elif path == '' or path.endswith('/'):
AttributeError: 'EmptySideInput' object has no attribute 'endswith' [while
running 'write/Write/WriteImpl/WriteBundles/Do']
root: INFO: 2017-05-22T22:12:06.900Z: JOB_MESSAGE_DEBUG: (b045f887a4163994):
Executing failure step failure24
root: INFO: 2017-05-22T22:12:06.901Z: JOB_MESSAGE_ERROR: (b045f887a416374e):
Workflow failed. Causes: (b045f887a4163743):
S08:group/Read+group/GroupByWindow+count+format+write/Write/WriteImpl/WriteBundles/Do+write/Write/WriteImpl/Pair+write/Write/WriteImpl/WindowInto(WindowIntoFn)+write/Write/WriteImpl/GroupByKey/Reify+write/Write/WriteImpl/GroupByKey/Write
failed.
root: INFO: 2017-05-22T22:12:06.959Z: JOB_MESSAGE_DETAILED: (7c0cf0e23d4a2b75):
Cleaning up.
root: INFO: 2017-05-22T22:12:07.091Z: JOB_MESSAGE_DEBUG: (7c0cf0e23d4a27e3):
Starting worker pool teardown.
root: INFO: 2017-05-22T22:12:07.093Z: JOB_MESSAGE_BASIC: (7c0cf0e23d4a2451):
Stopping worker pool...
root: INFO: 2017-05-22T22:13:17.103Z: JOB_MESSAGE_BASIC: (7c0cf0e23d4a26f6):
Worker pool stopped.
root: INFO: 2017-05-22T22:13:18.020Z: JOB_MESSAGE_DEBUG: (7c0cf0e23d4a2df8):
Tearing down pending resources...
root: INFO: Job 2017-05-22_15_07_57-15987798788201171093 is in state
JOB_STATE_FAILED
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 2 tests in 359.071s
FAILED (errors=1)
Found:
https://console.cloud.google.com/dataflow/job/2017-05-22_15_07_57-15987798788201171093?project=apache-beam-testing
Found:
https://console.cloud.google.com/dataflow/job/2017-05-22_15_07_56-7472617897051242709?project=apache-beam-testing
Build step 'Execute shell' marked build as failure
