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