[ https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563657#comment-17563657 ]
Huang Xingbo commented on FLINK-26456: -------------------------------------- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=37772&view=logs&j=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3&t=85189c57-d8a0-5c9c-b61d-fc05cfac62cf > 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, 1.15.0 > Reporter: Huang Xingbo > Assignee: Huang Xingbo > Priority: Major > Labels: stale-assigned, test-stability > > {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.10#820010)