You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/01/24 21:15:58 UTC
Build failed in Jenkins: beam_PostCommit_Python_Verify #1080
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/1080/>
------------------------------------------
[...truncated 12707 lines...]
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248e98a: 2017-01-24T21:01:50.858Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5d306): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ea0b: 2017-01-24T21:01:50.987Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5d6e9): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ea7b: 2017-01-24T21:01:51.099Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5dacc): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248eae5: 2017-01-24T21:01:51.205Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5deaf): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248eb6c: 2017-01-24T21:01:51.340Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5d99f): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ebe0: 2017-01-24T21:01:51.456Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5dd82): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ec45: 2017-01-24T21:01:51.557Z: JOB_MESSAGE_ERROR: (bc8e7d11a8c5d165): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ec6b: 2017-01-24T21:01:51.595Z: JOB_MESSAGE_DEBUG: (9494ff9fc45b0c11): Executing failure step failure1
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ec6d: 2017-01-24T21:01:51.597Z: JOB_MESSAGE_ERROR: (9494ff9fc45b09ef): Workflow failed. Causes: (76522a02aea32089): S03:DecorateWords+assert_that/WindowInto+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write failed.
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248eca8: 2017-01-24T21:01:51.656Z: JOB_MESSAGE_DETAILED: (fabfb321140b4ae0): Cleaning up.
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ed28: 2017-01-24T21:01:51.784Z: JOB_MESSAGE_DEBUG: (fabfb321140b4d76): Starting worker pool teardown.
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d248ed2a: 2017-01-24T21:01:51.786Z: JOB_MESSAGE_BASIC: (fabfb321140b400c): Stopping worker pool...
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d24a25b1: 2017-01-24T21:03:11.793Z: JOB_MESSAGE_BASIC: (fabfb321140b43ed): Worker pool stopped.
root: INFO: 2017-01-24_12_58_56-7577935156298903035_00000159d24a29af: 2017-01-24T21:03:12.815Z: JOB_MESSAGE_DEBUG: (fabfb321140b4baf): Tearing down pending resources...
root: INFO: Job 2017-01-24_12_58_56-7577935156298903035 is in state JOB_STATE_FAILED
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 20 tests in 4940.144s
FAILED (errors=12)
Build step 'Execute shell' marked build as failure
Jenkins build is back to normal : beam_PostCommit_Python_Verify
#1082
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/1082/changes>
Build failed in Jenkins: beam_PostCommit_Python_Verify #1081
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/1081/>
------------------------------------------
[...truncated 12631 lines...]
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a5151: 2017-01-24T22:30:45.841Z: JOB_MESSAGE_ERROR: (552f0c3b5a8d358): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a51d4: 2017-01-24T22:30:45.972Z: JOB_MESSAGE_ERROR: (552f0c3b5a8de3d): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a5237: 2017-01-24T22:30:46.071Z: JOB_MESSAGE_ERROR: (552f0c3b5a8d922): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a5298: 2017-01-24T22:30:46.168Z: JOB_MESSAGE_ERROR: (552f0c3b5a8d407): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a52f5: 2017-01-24T22:30:46.261Z: JOB_MESSAGE_ERROR: (552f0c3b5a8deec): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a5363: 2017-01-24T22:30:46.371Z: JOB_MESSAGE_ERROR: (552f0c3b5a8d9d1): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a53d5: 2017-01-24T22:30:46.485Z: JOB_MESSAGE_ERROR: (552f0c3b5a8d4b6): Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/dataflow_worker/batchworker.py", line 514, in do_work
work_executor.execute()
File "dataflow_worker/executor.py", line 899, in dataflow_worker.executor.MapTaskExecutor.execute (dataflow_worker/executor.c:26452)
op.start()
File "dataflow_worker/executor.py", line 191, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7575)
def start(self):
File "dataflow_worker/executor.py", line 196, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7480)
with self.spec.source.reader() as reader:
File "dataflow_worker/executor.py", line 206, in dataflow_worker.executor.ReadOperation.start (dataflow_worker/executor.c:7425)
self.output(windowed_value)
File "dataflow_worker/executor.py", line 136, in dataflow_worker.executor.Operation.output (dataflow_worker/executor.c:5749)
cython.cast(Receiver, self.receivers[output_index]).receive(windowed_value)
File "dataflow_worker/executor.py", line 83, in dataflow_worker.executor.ConsumerSet.receive (dataflow_worker/executor.c:3884)
cython.cast(Operation, consumer).process(windowed_value)
File "dataflow_worker/executor.py", line 505, in dataflow_worker.executor.DoOperation.process (dataflow_worker/executor.c:15525)
self.dofn_receiver.receive(o)
File "apache_beam/runners/common.py", line 160, in apache_beam.runners.common.DoFnRunner.receive (apache_beam/runners/common.c:4848)
self.process(windowed_value)
File "apache_beam/runners/common.py", line 267, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:7735)
self.reraise_augmented(exn)
File "apache_beam/runners/common.py", line 278, in apache_beam.runners.common.DoFnRunner.reraise_augmented (apache_beam/runners/common.c:8094)
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:7646)
self.old_dofn_process(element)
File "apache_beam/runners/common.py", line 170, in apache_beam.runners.common.DoFnRunner.old_dofn_process (apache_beam/runners/common.c:5168)
self._process_outputs(element, self.dofn_process(self.context))
File "apache_beam/runners/common.py", line 149, in apache_beam.runners.common.DoFnRunner.__init__.lambda3 (apache_beam/runners/common.c:3640)
self.dofn_process = lambda context: fn.process(context, *args)
File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/transforms/core.py",> line 339, in <lambda>
TypeError: <lambda>() takes exactly 3 arguments (2 given) [while running 'DecorateWords']
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a53fa: 2017-01-24T22:30:46.522Z: JOB_MESSAGE_DEBUG: (d6519e02528f165f): Executing failure step failure1
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a53fd: 2017-01-24T22:30:46.525Z: JOB_MESSAGE_ERROR: (d6519e02528f1645): Workflow failed. Causes: (fdce087e89d744bb): S03:DecorateWords+assert_that/WindowInto+assert_that/ToVoidKey+assert_that/Group/Reify+assert_that/Group/Write failed.
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a5437: 2017-01-24T22:30:46.583Z: JOB_MESSAGE_DETAILED: (9ced6ec8e3a4b6cd): Cleaning up.
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a54b9: 2017-01-24T22:30:46.713Z: JOB_MESSAGE_DEBUG: (9ced6ec8e3a4b26b): Starting worker pool teardown.
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29a54bb: 2017-01-24T22:30:46.715Z: JOB_MESSAGE_BASIC: (9ced6ec8e3a4be09): Stopping worker pool...
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29b6633: 2017-01-24T22:31:56.723Z: JOB_MESSAGE_BASIC: (9ced6ec8e3a4bf76): Worker pool stopped.
root: INFO: 2017-01-24_14_27_54-3794114228338257977_00000159d29b6a36: 2017-01-24T22:31:57.750Z: JOB_MESSAGE_DEBUG: (9ced6ec8e3a4b250): Tearing down pending resources...
root: INFO: Job 2017-01-24_14_27_54-3794114228338257977 is in state JOB_STATE_FAILED
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
Ran 20 tests in 5024.841s
FAILED (errors=12)
Build step 'Execute shell' marked build as failure