[FLINK-30163] StreamPandasUDFITTests.test_basic_functionality failed

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.2
• Component/s: API / Python
• Labels: test-stability
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 23/Nov/22 09:12
• Updated: 23/Nov/22 09:12

Description

This build failed due to StreamPandasUDFITTests.test_basic_functionality

ov 09 01:49:14 _______________ StreamPandasUDFITTests.test_basic_functionality ________________
Nov 09 01:49:14 
Nov 09 01:49:14 self = <pyflink.table.tests.test_pandas_udf.StreamPandasUDFITTests testMethod=test_basic_functionality>
Nov 09 01:49:14 
Nov 09 01:49:14     def test_basic_functionality(self):
Nov 09 01:49:14         # pandas UDF
Nov 09 01:49:14         add_one = udf(lambda i: i + 1, result_type=DataTypes.BIGINT(), func_type="pandas")
Nov 09 01:49:14     
Nov 09 01:49:14         # general Python UDF
Nov 09 01:49:14         subtract_one = udf(SubtractOne(), DataTypes.BIGINT(), DataTypes.BIGINT())
Nov 09 01:49:14     
Nov 09 01:49:14         table_sink = source_sink_utils.TestAppendSink(
Nov 09 01:49:14             ['a', 'b', 'c', 'd'],
Nov 09 01:49:14             [DataTypes.BIGINT(), DataTypes.BIGINT(), DataTypes.BIGINT(), DataTypes.BIGINT()])
Nov 09 01:49:14         self.t_env.register_table_sink("Results", table_sink)
Nov 09 01:49:14     
Nov 09 01:49:14         t = self.t_env.from_elements([(1, 2, 3), (2, 5, 6), (3, 1, 9)], ['a', 'b', 'c'])
Nov 09 01:49:14         t.where(add_one(t.b) <= 3) \
Nov 09 01:49:14             .select(t.a, t.b + 1, add(t.a + 1, subtract_one(t.c)) + 2, add(add_one(t.a), 1)) \
Nov 09 01:49:14 >           .execute_insert("Results") \
Nov 09 01:49:14             .wait()