[
https://issues.apache.org/jira/browse/BEAM-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Amato updated BEAM-12527:
------------------------------
Description:
[https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/]
[https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/consoleFull]|
05:14:44 E During handling of the above exception, another exception occurred:
05:14:44 E
05:14:44 E Traceback (most recent call last):
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 284, in _execute
05:14:44 E response = task()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 357, in <lambda>
05:14:44 E lambda: self.create_worker().do_instruction(request), request)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 602, in do_instruction
05:14:44 E getattr(request, request_type), request.instruction_id)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 633, in process_bundle
05:14:44 E instruction_id, request.process_bundle_descriptor_id)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 462, in get
05:14:44 E self.data_channel_factory)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 862, in __init__
05:14:44 E self.ops =
self.create_execution_tree(self.process_bundle_descriptor)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 919, in create_execution_tree
05:14:44 E descriptor.transforms, key=topological_height, reverse=True)])
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 918, in <listcomp>
05:14:44 E get_operation(transform_id))) for transform_id in sorted(
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 806, in wrapper
05:14:44 E result = cache[args] = func(*args)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 900, in get_operation
05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 900, in <dictcomp>
05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 898, in <listcomp>
05:14:44 E tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 806, in wrapper
05:14:44 E result = cache[args] = func(*args)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 903, in get_operation
05:14:44 E transform_id, transform_consumers)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1192, in create_operation
05:14:44 E return creator(self, transform_id, transform_proto, payload,
consumers)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1540, in create_par_do
05:14:44 E parameter)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1576, in _create_pardo_operation
05:14:44 E dofn_data = pickler.loads(serialized_fn)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/internal/pickler.py", line
289, in loads
05:14:44 E return dill.loads(s)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
275, in loads
05:14:44 E return load(file, ignore, **kwds)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
270, in load
05:14:44 E return Unpickler(file, ignore=ignore, **kwds).load()
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
472, in load
05:14:44 E obj = StockUnpickler.load(self)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
827, in _import_module
05:14:44 E return getattr(__import__(module, None, None, [obj]), obj)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/transforms/validate_runner_xlang_test.py",
line 58, in <module>
05:14:44 E import pytest
05:14:44 E ModuleNotFoundError: No module named 'pytest'
was:
https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/
[https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/consoleFull]|https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/consoleFull*]
05:14:44 E During handling of the above exception, another exception occurred:
05:14:44 E
05:14:44 E Traceback (most recent call last):
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 284, in _execute
05:14:44 E response = task()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 357, in <lambda>
05:14:44 E lambda: self.create_worker().do_instruction(request), request)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 602, in do_instruction
05:14:44 E getattr(request, request_type), request.instruction_id)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 633, in process_bundle
05:14:44 E instruction_id, request.process_bundle_descriptor_id)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 462, in get
05:14:44 E self.data_channel_factory)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 862, in __init__
05:14:44 E self.ops =
self.create_execution_tree(self.process_bundle_descriptor)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 919, in create_execution_tree
05:14:44 E descriptor.transforms, key=topological_height, reverse=True)])
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 918, in <listcomp>
05:14:44 E get_operation(transform_id))) for transform_id in sorted(
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 806, in wrapper
05:14:44 E result = cache[args] = func(*args)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 900, in get_operation
05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 900, in <dictcomp>
05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 898, in <listcomp>
05:14:44 E tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 806, in wrapper
05:14:44 E result = cache[args] = func(*args)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 903, in get_operation
05:14:44 E transform_id, transform_consumers)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1192, in create_operation
05:14:44 E return creator(self, transform_id, transform_proto, payload,
consumers)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1540, in create_par_do
05:14:44 E parameter)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1576, in _create_pardo_operation
05:14:44 E dofn_data = pickler.loads(serialized_fn)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/internal/pickler.py", line
289, in loads
05:14:44 E return dill.loads(s)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
275, in loads
05:14:44 E return load(file, ignore, **kwds)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
270, in load
05:14:44 E return Unpickler(file, ignore=ignore, **kwds).load()
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
472, in load
05:14:44 E obj = StockUnpickler.load(self)
05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
827, in _import_module
05:14:44 E return getattr(__import__(module, None, None, [obj]), obj)
05:14:44 E File
"/usr/local/lib/python3.6/site-packages/apache_beam/transforms/validate_runner_xlang_test.py",
line 58, in <module>
05:14:44 E import pytest
05:14:44 E ModuleNotFoundError: No module named 'pytest'
> beam_PostCommit_XVR_Direct failing (ModuleNotFoundError: No module named
> 'pytest')
> -----------------------------------------------------------------------------------
>
> Key: BEAM-12527
> URL: https://issues.apache.org/jira/browse/BEAM-12527
> Project: Beam
> Issue Type: Test
> Components: test-failures
> Reporter: Alex Amato
> Priority: P2
>
> [https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/]
> [https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1364/consoleFull]|
>
> 05:14:44 E During handling of the above exception, another exception occurred:
> 05:14:44 E
> 05:14:44 E Traceback (most recent call last):
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 284, in _execute
> 05:14:44 E response = task()
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 357, in <lambda>
> 05:14:44 E lambda: self.create_worker().do_instruction(request), request)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 602, in do_instruction
> 05:14:44 E getattr(request, request_type), request.instruction_id)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 633, in process_bundle
> 05:14:44 E instruction_id, request.process_bundle_descriptor_id)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 462, in get
> 05:14:44 E self.data_channel_factory)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 862, in __init__
> 05:14:44 E self.ops =
> self.create_execution_tree(self.process_bundle_descriptor)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 919, in create_execution_tree
> 05:14:44 E descriptor.transforms, key=topological_height, reverse=True)])
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 918, in <listcomp>
> 05:14:44 E get_operation(transform_id))) for transform_id in sorted(
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 806, in wrapper
> 05:14:44 E result = cache[args] = func(*args)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 900, in get_operation
> 05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 900, in <dictcomp>
> 05:14:44 E pcoll_id in descriptor.transforms[transform_id].outputs.items()
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 898, in <listcomp>
> 05:14:44 E tag: [get_operation(op) for op in pcoll_consumers[pcoll_id]]
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 806, in wrapper
> 05:14:44 E result = cache[args] = func(*args)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 903, in get_operation
> 05:14:44 E transform_id, transform_consumers)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 1192, in create_operation
> 05:14:44 E return creator(self, transform_id, transform_proto, payload,
> consumers)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 1540, in create_par_do
> 05:14:44 E parameter)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 1576, in _create_pardo_operation
> 05:14:44 E dofn_data = pickler.loads(serialized_fn)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/internal/pickler.py",
> line 289, in loads
> 05:14:44 E return dill.loads(s)
> 05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
> 275, in loads
> 05:14:44 E return load(file, ignore, **kwds)
> 05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
> 270, in load
> 05:14:44 E return Unpickler(file, ignore=ignore, **kwds).load()
> 05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
> 472, in load
> 05:14:44 E obj = StockUnpickler.load(self)
> 05:14:44 E File "/usr/local/lib/python3.6/site-packages/dill/_dill.py", line
> 827, in _import_module
> 05:14:44 E return getattr(__import__(module, None, None, [obj]), obj)
> 05:14:44 E File
> "/usr/local/lib/python3.6/site-packages/apache_beam/transforms/validate_runner_xlang_test.py",
> line 58, in <module>
> 05:14:44 E import pytest
> 05:14:44 E ModuleNotFoundError: No module named 'pytest'
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
