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 #2076
Date Tue, 02 May 2017 03:10:25 GMT
See <https://builds.apache.org/job/beam_PostCommit_Python_Verify/2076/display/redirect>

------------------------------------------
[...truncated 470.95 KB...]
test_with_http_error_that_should_not_be_retried (apache_beam.utils.retry_test.RetryTest) ...
ok
test_with_no_retry_decorator (apache_beam.utils.retry_test.RetryTest) ... ok
test_with_real_clock (apache_beam.utils.retry_test.RetryTest) ... ok
test_basic_test_stream (apache_beam.utils.test_stream_test.TestStreamTest) ... ok
test_test_stream_errors (apache_beam.utils.test_stream_test.TestStreamTest) ... ok
test_arithmetic (apache_beam.utils.timestamp_test.DurationTest) ... ok
test_of (apache_beam.utils.timestamp_test.DurationTest) ... ok
test_precision (apache_beam.utils.timestamp_test.DurationTest) ... ok
test_sort_order (apache_beam.utils.timestamp_test.DurationTest) ... ok
test_str (apache_beam.utils.timestamp_test.DurationTest) ... ok
test_arithmetic (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_of (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_precision (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_sort_order (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_str (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_utc_timestamp (apache_beam.utils.timestamp_test.TimestampTest) ... ok
test_runtime_value_provider_keyword_argument (apache_beam.utils.value_provider_test.ValueProviderTests)
... ok
test_runtime_value_provider_positional_argument (apache_beam.utils.value_provider_test.ValueProviderTests)
... ok
test_set_runtime_option (apache_beam.utils.value_provider_test.ValueProviderTests) ... ok
test_static_value_provider_keyword_argument (apache_beam.utils.value_provider_test.ValueProviderTests)
... ok
test_static_value_provider_positional_argument (apache_beam.utils.value_provider_test.ValueProviderTests)
... ok
test_static_value_provider_type_cast (apache_beam.utils.value_provider_test.ValueProviderTests)
... ok
test_equality (apache_beam.utils.windowed_value_test.WindowedValueTest) ... ok
test_hash (apache_beam.utils.windowed_value_test.WindowedValueTest) ... ok
test_pickle (apache_beam.utils.windowed_value_test.WindowedValueTest) ... ok
test_timestamps (apache_beam.utils.windowed_value_test.WindowedValueTest) ... ok
test_with_value (apache_beam.utils.windowed_value_test.WindowedValueTest) ... ok
test_element (apache_beam.pipeline_test.DoFnTest) ... ok
test_side_input_no_tag (apache_beam.pipeline_test.DoFnTest) ... ok
test_side_input_tagged (apache_beam.pipeline_test.DoFnTest) ... ok
test_timestamp_param (apache_beam.pipeline_test.DoFnTest) ... ok
test_window_param (apache_beam.pipeline_test.DoFnTest) ... ok
test_attribute_setting (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_defaults (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_dir (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_flag_parsing (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_keyword_parsing (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_view_as (apache_beam.pipeline_test.PipelineOptionsTest) ... ok
test_aggregator_empty_input (apache_beam.pipeline_test.PipelineTest) ... ok
test_apply_custom_transform (apache_beam.pipeline_test.PipelineTest) ... ok
test_create (apache_beam.pipeline_test.PipelineTest) ... ok
test_create_singleton_pcollection (apache_beam.pipeline_test.PipelineTest) ... ok
test_flatmap_builtin (apache_beam.pipeline_test.PipelineTest) ... ok
test_memory_usage (apache_beam.pipeline_test.PipelineTest) ... ok
test_metrics_in_source (apache_beam.pipeline_test.PipelineTest) ... ok
test_pipeline_as_context (apache_beam.pipeline_test.PipelineTest) ... <https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/coders/typecoders.py>:132:
UserWarning: Using fallback coder for typehint: <type 'type'>.
  warnings.warn('Using fallback coder for typehint: %r.' % typehint)
ok
test_read (apache_beam.pipeline_test.PipelineTest) ... ok
test_reuse_cloned_custom_transform_instance (apache_beam.pipeline_test.PipelineTest) ... ok
test_reuse_custom_transform_instance (apache_beam.pipeline_test.PipelineTest) ... <https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline_test.py>:196:
DeprecationWarning: BaseException.message has been deprecated as of Python 2.6
  cm.exception.message,
ok
test_transform_no_super_init (apache_beam.pipeline_test.PipelineTest) ... ok
test_visit_entire_graph (apache_beam.pipeline_test.PipelineTest) ... ok
test_simple (apache_beam.pipeline_test.RunnerApiTest)
Tests serializing, deserializing, and running a simple pipeline. ... ok
test_pvalue_expected_arguments (apache_beam.pvalue_test.PValueTest) ... ok
test_append_extra_options (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_append_verifier_in_extra_opt (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_create_test_pipeline_options (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_empty_option_args_parsing (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_get_option (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_option_args_parsing (apache_beam.test_pipeline_test.TestPipelineTest) ... ok
test_skip_IT (apache_beam.test_pipeline_test.TestPipelineTest) ... SKIP: IT is skipped because
--test-pipeline-options is not specified
test_file_checksum_matchcer_invalid_sleep_time (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
... <https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/tests/pipeline_verifiers_test.py>:129:
DeprecationWarning: BaseException.message has been deprecated as of Python 2.6
  self.assertEqual(cm.exception.message,
ok
test_file_checksum_matcher_read_failed (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
... ok
test_file_checksum_matcher_service_error (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
... ok
test_file_checksum_matcher_sleep_before_verify (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
... ok
test_file_checksum_matcher_success (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
... ok
test_pipeline_state_matcher_fails (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
Test PipelineStateMatcher fails when using default expected state ... ok
test_pipeline_state_matcher_given_state (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
Test PipelineStateMatcher successes when matches given state ... ok
test_pipeline_state_matcher_success (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest)
Test PipelineStateMatcher successes when using default expected state ... ok

======================================================================
ERROR: test_pardo_side_and_main_outputs (apache_beam.runners.portability.maptask_executor_runner_test.MapTaskExecutorRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py",>
line 129, in test_pardo_side_and_main_outputs
    assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 173, in __exit__
    self.run().wait_until_finish()
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 157, in run
    self.to_runner_api(), self.runner, self.options).run(False)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 166, in run
    return self.runner.run(self)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py",>
line 105, in run
    self.execute_map_tasks(ordered_map_tasks)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py",>
line 137, in execute_map_tasks
    map_executor.execute()
  File "apache_beam/runners/worker/operations.py", line 647, in apache_beam.runners.worker.operations.SimpleMapTaskExecutor.execute
(apache_beam/runners/worker/operations.c:19301)
    with op.scoped_metrics_container:
  File "apache_beam/runners/worker/operations.py", line 648, in apache_beam.runners.worker.operations.SimpleMapTaskExecutor.execute
(apache_beam/runners/worker/operations.c:19249)
    op.start()
  File "apache_beam/runners/worker/operations.py", line 202, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7886)
    def start(self):
  File "apache_beam/runners/worker/operations.py", line 203, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7790)
    with self.scoped_start_state:
  File "apache_beam/runners/worker/operations.py", line 212, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7733)
    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 "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 372, in apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:9972)
    self.process(windowed_value)
  File "apache_beam/runners/common.py", line 380, in apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10274)
    self._reraise_augmented(exn)
  File "apache_beam/runners/common.py", line 410, in apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11277)
    raise type(exn), args, sys.exc_info()[2]
  File "apache_beam/runners/common.py", line 378, in apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10187)
    self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 181, in apache_beam.runners.common.SimpleInvoker.invoke_process
(apache_beam/runners/common.c:6086)
    self.output_processor.process_outputs(
  File "apache_beam/runners/common.py", line 439, in apache_beam.runners.common.OutputProcessor.process_outputs
(apache_beam/runners/common.c:11638)
    for result in results:
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py",>
line 116, in even_odd
    yield beam.pvalue.OutputValue('odd' if elem % 2 else 'even', elem)
AttributeError: 'module' object has no attribute 'OutputValue' [while running 'named/FlatMap(even_odd)']
-------------------- >> begin captured logging << --------------------
root: INFO: Running [(u'Create/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource
object at 0x7f80daf11650>, start_position=None, stop_position=None))), (u'named/FlatMap(even_odd)',
WorkerDoFn(output_tags=['out', 'out_even', 'out_odd'], input=(0, 0))), (u'named.all/WindowInto(WindowIntoFn)',
WorkerDoFn(output_tags=['out'], input=(1, 0))), (u'named.all/ToVoidKey', WorkerDoFn(output_tags=['out'],
input=(2, 0))), (u'named.all/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(3,
0))), (u'named.all/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(4, 0))), (u'named.even/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'],
input=(1, 1))), (u'named.even/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(6, 0))),
(u'named.even/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(7, 0))), (u'named.even/Group/Flatten/Write',
WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(8,
0))), (u'named.odd/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(1, 2))),
(u'named.odd/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(10, 0))), (u'named.odd/Group/pair_with_1',
WorkerDoFn(output_tags=['out'], input=(11, 0))), (u'named.odd/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(12, 0))), (u'unnamed/FlatMap(even_odd)', WorkerDoFn(output_tags=['out',
'out_even', 'out_odd'], input=(0, 0))), (u'Map(id)', WorkerDoFn(output_tags=['out'], input=(14,
0))), (u'unnamed.all/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(14,
0))), (u'unnamed.all/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(16, 0))), (u'unnamed.all/Group/pair_with_1',
WorkerDoFn(output_tags=['out'], input=(17, 0))), (u'unnamed.all/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(18, 0))), (u'unnamed.even/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'],
input=(14, 1))), (u'unnamed.even/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(20, 0))),
(u'unnamed.even/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(21, 0))), (u'unnamed.even/Group/Flatten/Write',
WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(22,
0))), (u'unnamed.odd/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(14,
2))), (u'unnamed.odd/ToVoidKey', WorkerDoFn(output_tags=['out'], input=(24, 0))), (u'unnamed.odd/Group/pair_with_1',
WorkerDoFn(output_tags=['out'], input=(25, 0))), (u'unnamed.odd/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(26, 0)))]
root: DEBUG: Starting op 27 <InMemoryWriteOperation unnamed.odd/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(26, 0)>
root: DEBUG: Starting op 26 <DoOperation unnamed.odd/Group/pair_with_1 output_tags=['out'],
input=(25, 0)>
root: DEBUG: Starting op 25 <DoOperation unnamed.odd/ToVoidKey output_tags=['out'], input=(24,
0)>
root: DEBUG: Starting op 24 <DoOperation unnamed.odd/WindowInto(WindowIntoFn) output_tags=['out'],
input=(14, 2)>
root: DEBUG: Starting op 23 <InMemoryWriteOperation unnamed.even/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(22, 0)>
root: DEBUG: Starting op 22 <DoOperation unnamed.even/Group/pair_with_1 output_tags=['out'],
input=(21, 0)>
root: DEBUG: Starting op 21 <DoOperation unnamed.even/ToVoidKey output_tags=['out'], input=(20,
0)>
root: DEBUG: Starting op 20 <DoOperation unnamed.even/WindowInto(WindowIntoFn) output_tags=['out'],
input=(14, 1)>
root: DEBUG: Starting op 19 <InMemoryWriteOperation unnamed.all/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(18, 0)>
root: DEBUG: Starting op 18 <DoOperation unnamed.all/Group/pair_with_1 output_tags=['out'],
input=(17, 0)>
root: DEBUG: Starting op 17 <DoOperation unnamed.all/ToVoidKey output_tags=['out'], input=(16,
0)>
root: DEBUG: Starting op 16 <DoOperation unnamed.all/WindowInto(WindowIntoFn) output_tags=['out'],
input=(14, 0)>
root: DEBUG: Starting op 15 <DoOperation Map(id) output_tags=['out'], input=(14, 0)>
root: DEBUG: Starting op 14 <DoOperation unnamed/FlatMap(even_odd) output_tags=['out',
'out_even', 'out_odd'], input=(0, 0)>
root: DEBUG: Starting op 13 <InMemoryWriteOperation named.odd/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(12, 0)>
root: DEBUG: Starting op 12 <DoOperation named.odd/Group/pair_with_1 output_tags=['out'],
input=(11, 0)>
root: DEBUG: Starting op 11 <DoOperation named.odd/ToVoidKey output_tags=['out'], input=(10,
0)>
root: DEBUG: Starting op 10 <DoOperation named.odd/WindowInto(WindowIntoFn) output_tags=['out'],
input=(1, 2)>
root: DEBUG: Starting op 9 <InMemoryWriteOperation named.even/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(8, 0)>
root: DEBUG: Starting op 8 <DoOperation named.even/Group/pair_with_1 output_tags=['out'],
input=(7, 0)>
root: DEBUG: Starting op 7 <DoOperation named.even/ToVoidKey output_tags=['out'], input=(6,
0)>
root: DEBUG: Starting op 6 <DoOperation named.even/WindowInto(WindowIntoFn) output_tags=['out'],
input=(1, 1)>
root: DEBUG: Starting op 5 <InMemoryWriteOperation named.all/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(4, 0)>
root: DEBUG: Starting op 4 <DoOperation named.all/Group/pair_with_1 output_tags=['out'],
input=(3, 0)>
root: DEBUG: Starting op 3 <DoOperation named.all/ToVoidKey output_tags=['out'], input=(2,
0)>
root: DEBUG: Starting op 2 <DoOperation named.all/WindowInto(WindowIntoFn) output_tags=['out'],
input=(1, 0)>
root: DEBUG: Starting op 1 <DoOperation named/FlatMap(even_odd) output_tags=['out', 'out_even',
'out_odd'], input=(0, 0)>
root: DEBUG: Starting op 0 <ReadOperation Create/Read source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource
object at 0x7f80daf11650>, start_position=None, stop_position=None)>
root: DEBUG: Processing [((None, (1, 1)), MIN_TIMESTAMP, [GlobalWindow])] in <InMemoryWriteOperation
named.all/Group/Flatten/Write output_buffer=GroupingOutput[0], write_windowed_values=True,
input=(4, 0), receivers=[ConsumerSet[named.all/Group/Flatten/Write.out0, coder=WindowedValueCoder[TupleCoder[FastPrimitivesCoder,
TupleCoder[FastPrimitivesCoder, FastPrimitivesCoder]]], len(consumers)=0]]>
--------------------- >> end captured logging << ---------------------

======================================================================
ERROR: test_pardo_side_outputs (apache_beam.runners.portability.maptask_executor_runner_test.MapTaskExecutorRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py",>
line 111, in test_pardo_side_outputs
    assert_that(xy.y, equal_to(['y', 'xy']), label='y')
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 173, in __exit__
    self.run().wait_until_finish()
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 157, in run
    self.to_runner_api(), self.runner, self.options).run(False)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/pipeline.py",>
line 166, in run
    return self.runner.run(self)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py",>
line 105, in run
    self.execute_map_tasks(ordered_map_tasks)
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner.py",>
line 137, in execute_map_tasks
    map_executor.execute()
  File "apache_beam/runners/worker/operations.py", line 647, in apache_beam.runners.worker.operations.SimpleMapTaskExecutor.execute
(apache_beam/runners/worker/operations.c:19301)
    with op.scoped_metrics_container:
  File "apache_beam/runners/worker/operations.py", line 648, in apache_beam.runners.worker.operations.SimpleMapTaskExecutor.execute
(apache_beam/runners/worker/operations.c:19249)
    op.start()
  File "apache_beam/runners/worker/operations.py", line 202, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7886)
    def start(self):
  File "apache_beam/runners/worker/operations.py", line 203, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7790)
    with self.scoped_start_state:
  File "apache_beam/runners/worker/operations.py", line 212, in apache_beam.runners.worker.operations.ReadOperation.start
(apache_beam/runners/worker/operations.c:7733)
    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 "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 372, in apache_beam.runners.common.DoFnRunner.receive
(apache_beam/runners/common.c:9972)
    self.process(windowed_value)
  File "apache_beam/runners/common.py", line 380, in apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10274)
    self._reraise_augmented(exn)
  File "apache_beam/runners/common.py", line 410, in apache_beam.runners.common.DoFnRunner._reraise_augmented
(apache_beam/runners/common.c:11277)
    raise type(exn), args, sys.exc_info()[2]
  File "apache_beam/runners/common.py", line 378, in apache_beam.runners.common.DoFnRunner.process
(apache_beam/runners/common.c:10187)
    self.do_fn_invoker.invoke_process(windowed_value)
  File "apache_beam/runners/common.py", line 273, in apache_beam.runners.common.PerWindowInvoker.invoke_process
(apache_beam/runners/common.c:8442)
    self._invoke_per_window(windowed_value)
  File "apache_beam/runners/common.py", line 298, in apache_beam.runners.common.PerWindowInvoker._invoke_per_window
(apache_beam/runners/common.c:9129)
    self.output_processor.process_outputs(
  File "apache_beam/runners/common.py", line 439, in apache_beam.runners.common.OutputProcessor.process_outputs
(apache_beam/runners/common.c:11638)
    for result in results:
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/runners/portability/maptask_executor_runner_test.py",>
line 105, in tee
    yield beam.pvalue.OutputValue(tag, elem)
AttributeError: 'module' object has no attribute 'OutputValue' [while running 'FlatMap(tee)/FlatMap(tee)']
-------------------- >> begin captured logging << --------------------
root: INFO: Running [(u'Create/Read', WorkerRead(source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource
object at 0x7f80d83a51d0>, start_position=None, stop_position=None))), (u'FlatMap(tee)/FlatMap(tee)',
WorkerDoFn(output_tags=['out', 'out_y', 'out_x'], input=(0, 0))), (u'x/WindowInto(WindowIntoFn)',
WorkerDoFn(output_tags=['out'], input=(1, 2))), (u'x/ToVoidKey', WorkerDoFn(output_tags=['out'],
input=(2, 0))), (u'x/Group/pair_with_1', WorkerDoFn(output_tags=['out'], input=(3, 0))), (u'x/Group/Flatten/Write',
WorkerInMemoryWrite(output_buffer=GroupingOutput[0], write_windowed_values=True, input=(4,
0))), (u'y/WindowInto(WindowIntoFn)', WorkerDoFn(output_tags=['out'], input=(1, 1))), (u'y/ToVoidKey',
WorkerDoFn(output_tags=['out'], input=(6, 0))), (u'y/Group/pair_with_1', WorkerDoFn(output_tags=['out'],
input=(7, 0))), (u'y/Group/Flatten/Write', WorkerInMemoryWrite(output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(8, 0)))]
root: DEBUG: Starting op 9 <InMemoryWriteOperation y/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(8, 0)>
root: DEBUG: Starting op 8 <DoOperation y/Group/pair_with_1 output_tags=['out'], input=(7,
0)>
root: DEBUG: Starting op 7 <DoOperation y/ToVoidKey output_tags=['out'], input=(6, 0)>
root: DEBUG: Starting op 6 <DoOperation y/WindowInto(WindowIntoFn) output_tags=['out'],
input=(1, 1)>
root: DEBUG: Starting op 5 <InMemoryWriteOperation x/Group/Flatten/Write output_buffer=GroupingOutput[0],
write_windowed_values=True, input=(4, 0)>
root: DEBUG: Starting op 4 <DoOperation x/Group/pair_with_1 output_tags=['out'], input=(3,
0)>
root: DEBUG: Starting op 3 <DoOperation x/ToVoidKey output_tags=['out'], input=(2, 0)>
root: DEBUG: Starting op 2 <DoOperation x/WindowInto(WindowIntoFn) output_tags=['out'],
input=(1, 2)>
root: DEBUG: Starting op 1 <DoOperation FlatMap(tee)/FlatMap(tee) output_tags=['out', 'out_y',
'out_x'], input=(0, 0)>
root: DEBUG: Starting op 0 <ReadOperation Create/Read source=SourceBundle(weight=1.0, source=<apache_beam.transforms.core._CreateSource
object at 0x7f80d83a51d0>, start_position=None, stop_position=None)>
--------------------- >> end captured logging << ---------------------

======================================================================
FAIL: test_using_slow_impl (apache_beam.coders.slow_coders_test.SlowCoders)
----------------------------------------------------------------------
Traceback (most recent call last):
  File "<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/apache_beam/coders/slow_coders_test.py",>
line 41, in test_using_slow_impl
    import apache_beam.coders.stream
AssertionError: ImportError not raised

----------------------------------------------------------------------
Ran 1198 tests in 118.156s

FAILED (failures=1, errors=2, skipped=15)
Test failed: <unittest.runner.TextTestResult run=1198 errors=2 failures=1>
error: Test failed: <unittest.runner.TextTestResult run=1198 errors=2 failures=1>
ERROR: InvocationError: '<https://builds.apache.org/job/beam_PostCommit_Python_Verify/ws/sdks/python/target/.tox/py27gcp/bin/python>
setup.py test'
___________________________________ summary ____________________________________
  docs: commands succeeded
  lint: commands succeeded
ERROR:   py27: commands failed
ERROR:   py27cython: commands failed
ERROR:   py27gcp: commands failed
Build step 'Execute shell' marked build as failure
Not sending mail to unregistered user kirpichov@google.com

Mime
View raw message