Huang Xingbo created FLINK-26456:
------------------------------------
Summary: StreamExecutionEnvironmentTests::test_add_python_file
failed with ModuleNotFoundError
Key: FLINK-26456
URL: https://issues.apache.org/jira/browse/FLINK-26456
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.14.0
Reporter: Huang Xingbo
{code:java}
2022-03-02T16:33:43.6649755Z Mar 02 16:33:43 Traceback (most recent call last):
2022-03-02T16:33:43.6650839Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 289, in _execute
2022-03-02T16:33:43.6651405Z Mar 02 16:33:43 response = task()
2022-03-02T16:33:43.6652257Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 362, in <lambda>
2022-03-02T16:33:43.6652846Z Mar 02 16:33:43 lambda:
self.create_worker().do_instruction(request), request)
2022-03-02T16:33:43.6653655Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 606, in do_instruction
2022-03-02T16:33:43.6654200Z Mar 02 16:33:43 return getattr(self,
request_type)(
2022-03-02T16:33:43.6654969Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 644, in process_bundle
2022-03-02T16:33:43.6655549Z Mar 02 16:33:43
bundle_processor.process_bundle(instruction_id))
2022-03-02T16:33:43.6656337Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 999, in process_bundle
2022-03-02T16:33:43.6656936Z Mar 02 16:33:43
input_op_by_transform_id[element.transform_id].process_encoded(
2022-03-02T16:33:43.6657773Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/.tox/py38/lib/python3.8/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 228, in process_encoded
2022-03-02T16:33:43.6658326Z Mar 02 16:33:43 self.output(decoded_value)
2022-03-02T16:33:43.6658829Z Mar 02 16:33:43 File
"apache_beam/runners/worker/operations.py", line 357, in
apache_beam.runners.worker.operations.Operation.output
2022-03-02T16:33:43.6659460Z Mar 02 16:33:43 File
"apache_beam/runners/worker/operations.py", line 359, in
apache_beam.runners.worker.operations.Operation.output
2022-03-02T16:33:43.6660261Z Mar 02 16:33:43 File
"apache_beam/runners/worker/operations.py", line 221, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
2022-03-02T16:33:43.6661064Z Mar 02 16:33:43 File
"apache_beam/runners/worker/operations.py", line 319, in
apache_beam.runners.worker.operations.Operation.process
2022-03-02T16:33:43.6661902Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line
132, in process
2022-03-02T16:33:43.6662440Z Mar 02 16:33:43
self._output_processor.process_outputs(o, self.process_element(value))
2022-03-02T16:33:43.6663200Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line
63, in process_outputs
2022-03-02T16:33:43.6663750Z Mar 02 16:33:43
self._consumer.process(windowed_value.with_value(results))
2022-03-02T16:33:43.6664475Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line
131, in process
2022-03-02T16:33:43.6664969Z Mar 02 16:33:43 for value in o.value:
2022-03-02T16:33:43.6665754Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/fn_execution/datastream/operations.py", line
179, in wrapped_func
2022-03-02T16:33:43.6666280Z Mar 02 16:33:43 yield from
_emit_results(timestamp, watermark, results)
2022-03-02T16:33:43.6667010Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/fn_execution/datastream/input_handler.py", line
101, in _emit_results
2022-03-02T16:33:43.6667492Z Mar 02 16:33:43 for result in results:
2022-03-02T16:33:43.6668154Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/datastream/data_stream.py", line 271, in
process_element
2022-03-02T16:33:43.6668626Z Mar 02 16:33:43 yield self._map_func(value)
2022-03-02T16:33:43.6669335Z Mar 02 16:33:43 File
"/__w/2/s/flink-python/pyflink/datastream/tests/test_stream_execution_environment.py",
line 350, in plus_two_map
2022-03-02T16:33:43.6669848Z Mar 02 16:33:43 from test_dep1 import add_two
2022-03-02T16:33:43.6670561Z Mar 02 16:33:43 ModuleNotFoundError: No module
named 'test_dep1'
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32448&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
