[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705216#comment-17705216
]
Matthias Pohl commented on FLINK-26974:
---------------------------------------
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47582&view=logs&j=bf5e383b-9fd3-5f02-ca1c-8f788e2e76d3&t=85189c57-d8a0-5c9c-b61d-fc05cfac62cf&l=29429
{code}
[...]
Mar 25 03:12:29 E Caused by: pemja.core.PythonException:
<class 'Exception'>: This function should not be called!
Mar 25 03:12:29 E at
/__w/1/s/flink-python/pyflink/fn_execution/table/operations.process_element(operations.py:83)
Mar 25 03:12:29 E at <string>.<lambda>(<string>:1)
Mar 25 03:12:29 E at
/__w/1/s/flink-python/pyflink/table/tests/test_dependency.plus_two(test_dependency.py:55)
Mar 25 03:12:29 E at
/tmp/python-dist-d894b8cb-a8ed-453c-af16-d5165b46a55a/python-files/blob_p-bedc014754a86159784fd7cebff77ab534802643-48c40e738ccf138321bc62ad6fe9ad3f/test_dependency_manage_lib.add_two(test_dependency_manage_lib.py:2)
Mar 25 03:12:29 E at
pemja.core.PythonInterpreter.invokeMethodOneArgLong(Native Method)
Mar 25 03:12:29 E at
pemja.core.PythonInterpreter.invokeMethodOneArg(PythonInterpreter.java:223)
Mar 25 03:12:29 E at
pemja.core.PythonInterpreter.invokeMethod(PythonInterpreter.java:117)
Mar 25 03:12:29 E at
org.apache.flink.table.runtime.operators.python.scalar.EmbeddedPythonScalarFunctionOperator.processElement(EmbeddedPythonScalarFunctionOperator.java:206)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
Mar 25 03:12:29 E at
SourceConversion$21.processElement(Unknown Source)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
Mar 25 03:12:29 E at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
Mar 25 03:12:29 E at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332)
{code}
> Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure
> -------------------------------------------------------------------------
>
> Key: FLINK-26974
> URL: https://issues.apache.org/jira/browse/FLINK-26974
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.15.0, 1.16.0, 1.17.0
> Reporter: Yun Gao
> Assignee: Huang Xingbo
> Priority: Critical
> Labels: auto-deprioritized-major, test-stability
>
> {code:java}
> Mar 31 10:49:17 =================================== FAILURES
> ===================================
> Mar 31 10:49:17 ______________
> EmbeddedThreadDependencyTests.test_add_python_file ______________
> Mar 31 10:49:17
> Mar 31 10:49:17 self =
> <pyflink.table.tests.test_dependency.EmbeddedThreadDependencyTests
> testMethod=test_add_python_file>
> Mar 31 10:49:17
> Mar 31 10:49:17 def test_add_python_file(self):
> Mar 31 10:49:17 python_file_dir = os.path.join(self.tempdir,
> "python_file_dir_" + str(uuid.uuid4()))
> Mar 31 10:49:17 os.mkdir(python_file_dir)
> Mar 31 10:49:17 python_file_path = os.path.join(python_file_dir,
> "test_dependency_manage_lib.py")
> Mar 31 10:49:17 with open(python_file_path, 'w') as f:
> Mar 31 10:49:17 f.write("def add_two(a):\n raise
> Exception('This function should not be called!')")
> Mar 31 10:49:17 self.t_env.add_python_file(python_file_path)
> Mar 31 10:49:17
> Mar 31 10:49:17 python_file_dir_with_higher_priority = os.path.join(
> Mar 31 10:49:17 self.tempdir, "python_file_dir_" +
> str(uuid.uuid4()))
> Mar 31 10:49:17 os.mkdir(python_file_dir_with_higher_priority)
> Mar 31 10:49:17 python_file_path_higher_priority =
> os.path.join(python_file_dir_with_higher_priority,
> Mar 31 10:49:17
> "test_dependency_manage_lib.py")
> Mar 31 10:49:17 with open(python_file_path_higher_priority, 'w') as f:
> Mar 31 10:49:17 f.write("def add_two(a):\n return a + 2")
> Mar 31 10:49:17
> self.t_env.add_python_file(python_file_path_higher_priority)
> Mar 31 10:49:17
> Mar 31 10:49:17 def plus_two(i):
> Mar 31 10:49:17 from test_dependency_manage_lib import add_two
> Mar 31 10:49:17 return add_two(i)
> Mar 31 10:49:17
> Mar 31 10:49:17 self.t_env.create_temporary_system_function(
> Mar 31 10:49:17 "add_two", udf(plus_two, DataTypes.BIGINT(),
> DataTypes.BIGINT()))
> Mar 31 10:49:17 table_sink = source_sink_utils.TestAppendSink(
> Mar 31 10:49:17 ['a', 'b'], [DataTypes.BIGINT(),
> DataTypes.BIGINT()])
> Mar 31 10:49:17 self.t_env.register_table_sink("Results", table_sink)
> Mar 31 10:49:17 t = self.t_env.from_elements([(1, 2), (2, 5), (3,
> 1)], ['a', 'b'])
> Mar 31 10:49:17 > t.select(expr.call("add_two", t.a),
> t.a).execute_insert("Results").wait()
> Mar 31 10:49:17
> Mar 31 10:49:17 pyflink/table/tests/test_dependency.py:63:
> Mar 31 10:49:17 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _
> Mar 31 10:49:17 pyflink/table/table_result.py:76: in wait
> Mar 31 10:49:17 get_method(self._j_table_result, "await")()
> Mar 31 10:49:17
> .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1321: in
> __call__
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=34001&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295&l=27239
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
