[
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)
