[FLINK-23790] Python test_udtf.py fail on azure

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: API / Python
• Labels: test-stability
• Assignee: Unassigned
• Reporter: Xintong Song
• Created: 16/Aug/21 04:00
• Updated: 16/Aug/21 09:43
• Resolved: 16/Aug/21 09:43

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22196&view=logs&j=bdd9ea51-4de2-506a-d4d9-f3930e4d2355&t=dd50312f-73b5-56b5-c172-4d81d03e2ef1&l=23969

Aug 15 00:10:41 =================================== FAILURES ===================================
Aug 15 00:10:41 __________ PyFlinkStreamUserDefinedFunctionTests.test_table_function ___________
Aug 15 00:10:41 
Aug 15 00:10:41 self = <pyflink.table.tests.test_udtf.PyFlinkStreamUserDefinedFunctionTests testMethod=test_table_function>
Aug 15 00:10:41 
Aug 15 00:10:41     def test_table_function(self):
Aug 15 00:10:41         self._register_table_sink(
Aug 15 00:10:41             ['a', 'b', 'c'],
Aug 15 00:10:41             [DataTypes.BIGINT(), DataTypes.BIGINT(), DataTypes.BIGINT()])
Aug 15 00:10:41     
Aug 15 00:10:41         multi_emit = udtf(MultiEmit(), result_types=[DataTypes.BIGINT(), DataTypes.BIGINT()])
Aug 15 00:10:41         multi_num = udf(MultiNum(), result_type=DataTypes.BIGINT())
Aug 15 00:10:41     
Aug 15 00:10:41         t = self.t_env.from_elements([(1, 1, 3), (2, 1, 6), (3, 2, 9)], ['a', 'b', 'c'])
Aug 15 00:10:41         t = t.join_lateral(multi_emit((t.a + t.a) / 2, multi_num(t.b)).alias('x', 'y'))
Aug 15 00:10:41         t = t.left_outer_join_lateral(condition_multi_emit(t.x, t.y).alias('m')) \
Aug 15 00:10:41             .select("x, y, m")
Aug 15 00:10:41         t = t.left_outer_join_lateral(identity(t.m).alias('n')) \
Aug 15 00:10:41             .select("x, y, n")
Aug 15 00:10:41 >       actual = self._get_output(t)
Aug 15 00:10:41 
Aug 15 00:10:41 pyflink/table/tests/test_udtf.py:43: 
Aug 15 00:10:41 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
Aug 15 00:10:41 pyflink/table/tests/test_udtf.py:70: in _get_output
Aug 15 00:10:41     t.execute_insert("Results").wait()
Aug 15 00:10:41 pyflink/table/table_result.py:76: in wait
Aug 15 00:10:41     get_method(self._j_table_result, "await")()
Aug 15 00:10:41 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1285: in __call__
Aug 15 00:10:41     return_value = get_return_value(
Aug 15 00:10:41 pyflink/util/exceptions.py:146: in deco
Aug 15 00:10:41     return f(*a, **kw)
Aug 15 00:10:41 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

Issue Links

• duplicates: FLINK-23765 PythonTableFunctionOperatorTestBase java.lang.NullPointerException