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_Python_Verify #2287
Date Mon, 22 May 2017 22:13:55 GMT
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

Mime
View raw message