[
https://issues.apache.org/jira/browse/FLINK-31524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702481#comment-17702481
]
Matthias Pohl commented on FLINK-31524:
---------------------------------------
[~dianfu] [~hxbks2ks] can you verify that it's a not a blocker, i.e. it's
either a test code issue or related to 1.17-specific changes?
> StreamDependencyTests.test_add_python_file failed
> -------------------------------------------------
>
> Key: FLINK-31524
> URL: https://issues.apache.org/jira/browse/FLINK-31524
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Priority: Blocker
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47318&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295&l=24508
> Being caused by a "No module named 'test_dependency_manage_lib'" error:
> {code}
> [...]
> Mar 18 05:42:33 E Caused by:
> java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error
> received from SDK harness for instruction 1: Traceback (most recent call
> last):
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 287, in _execute
> Mar 18 05:42:33 E response = task()
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 360, in <lambda>
> Mar 18 05:42:33 E lambda:
> self.create_worker().do_instruction(request), request)
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 597, in do_instruction
> Mar 18 05:42:33 E getattr(request, request_type),
> request.instruction_id)
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 634, in process_bundle
> Mar 18 05:42:33 E
> bundle_processor.process_bundle(instruction_id))
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 1004, in process_bundle
> Mar 18 05:42:33 E element.data)
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 227, in process_encoded
> Mar 18 05:42:33 E self.output(decoded_value)
> Mar 18 05:42:33 E File
> "apache_beam/runners/worker/operations.py", line 526, in
> apache_beam.runners.worker.operations.Operation.output
> Mar 18 05:42:33 E File
> "apache_beam/runners/worker/operations.py", line 528, in
> apache_beam.runners.worker.operations.Operation.output
> Mar 18 05:42:33 E File
> "apache_beam/runners/worker/operations.py", line 237, in
> apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
> Mar 18 05:42:33 E File
> "apache_beam/runners/worker/operations.py", line 240, in
> apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
> Mar 18 05:42:33 E File
> "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 169, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> Mar 18 05:42:33 E File
> "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 196, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/pyflink/fn_execution/table/operations.py", line 110,
> in process_element
> Mar 18 05:42:33 E return self.func(value)
> Mar 18 05:42:33 E File "<string>", line 1, in <lambda>
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/pyflink/table/tests/test_dependency.py", line 51, in
> plus_two
> Mar 18 05:42:33 E from test_dependency_manage_lib
> import add_two
> Mar 18 05:42:33 E ModuleNotFoundError: No module named
> 'test_dependency_manage_lib'
> Mar 18 05:42:33 E
> Mar 18 05:42:33 E at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> Mar 18 05:42:33 E at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> Mar 18 05:42:33 E at
> org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:61)
> Mar 18 05:42:33 E at
> org.apache.beam.runners.fnexecution.control.SdkHarnessClient$BundleProcessor$ActiveBundle.close(SdkHarnessClient.java:504)
> Mar 18 05:42:33 E at
> org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory$1.close(DefaultJobBundleFactory.java:555)
> Mar 18 05:42:33 E at
> org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.finishBundle(BeamPythonFunctionRunner.java:414)
> Mar 18 05:42:33 E ... 7 more
> Mar 18 05:42:33 E Caused by: java.lang.RuntimeException:
> Error received from SDK harness for instruction 1: Traceback (most recent
> call last):
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 287, in _execute
> Mar 18 05:42:33 E response = task()
> Mar 18 05:42:33 E File
> "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 360, in <lambda>
> Mar 18 05:42:33 E lambda:
> self.create_worker().do_instruction(request), request)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
