You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Flink Jira Bot (Jira)" <ji...@apache.org> on 2022/07/06 10:41:00 UTC
[jira] [Updated] (FLINK-26456) StreamExecutionEnvironmentTests::test_add_python_file failed with ModuleNotFoundError
[ https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-26456:
-----------------------------------
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issue is assigned but has not received an update in 30 days, so it has been labeled "stale-assigned".
If you are still working on the issue, please remove the label and add a comment updating the community on your progress. If this issue is waiting on feedback, please consider this a reminder to the committer/reviewer. Flink is a very active project, and so we appreciate your patience.
If you are no longer working on the issue, please unassign yourself so someone else may work on it.
> 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)