[jira] [Created] (FLINK-26456) StreamExecutionEnvironmentTests::test_add_python_file failed with ModuleNotFoundError

["Huang Xingbo (Jira)" <ji...@apache.org>]

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)