[
https://issues.apache.org/jira/browse/FLINK-34011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-34011.
---------------------------------
Resolution: Duplicate
Closing this issue in favor of FLINK-26974.
> EmbeddedThreadDependencyTests.test_add_python_file fails with This function
> should not be called!
> -------------------------------------------------------------------------------------------------
>
> Key: FLINK-34011
> URL: https://issues.apache.org/jira/browse/FLINK-34011
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.18.2
> Reporter: Sergey Nuyanzin
> Priority: Major
> Labels: test-stability
>
> This build
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55966&view=logs&j=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3&t=85189c57-d8a0-5c9c-b61d-fc05cfac62cf&l=27052
> fails as
> {noformat}
> Jan 02 03:27:17 E Caused by: pemja.core.PythonException:
> <class 'Exception'>: This function should not be called!
> Jan 02 03:27:17 E at
> /__w/1/s/flink-python/pyflink/fn_execution/embedded/operation_utils.process_element(operation_utils.py:72)
> Jan 02 03:27:17 E at
> /__w/1/s/flink-python/pyflink/fn_execution/table/operations.process_element(operations.py:102)
> Jan 02 03:27:17 E at <string>.<lambda>(<string>:1)
> Jan 02 03:27:17 E at
> /__w/1/s/flink-python/pyflink/table/tests/test_dependency.plus_two(test_dependency.py:52)
> Jan 02 03:27:17 E at
> /tmp/python-dist-98ae39ca-f087-4122-8e67-f358a13f57c7/python-files/blob_p-bedc014754a86159784fd7cebff77ab534802643-43ac971c5ca669babbfe4ee1d5a1ad0e/test_dependency_manage_lib.add_two(test_dependency_manage_lib.py:2)
> Jan 02 03:27:17 E at
> pemja.core.PythonInterpreter.invokeMethodOneArgLong(Native Method)
> Jan 02 03:27:17 E at
> pemja.core.PythonInterpreter.invokeMethodOneArg(PythonInterpreter.java:222)
> Jan 02 03:27:17 E at
> pemja.core.PythonInterpreter.invokeMethod(PythonInterpreter.java:116)
> Jan 02 03:27:17 E at
> org.apache.flink.table.runtime.operators.python.scalar.EmbeddedPythonScalarFunctionOperator.processElement(EmbeddedPythonScalarFunctionOperator.java:170)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:425)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:520)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:110)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:99)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:114)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:71)
> Jan 02 03:27:17 E at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:338)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
