Robert Metzger created FLINK-19842:
--------------------------------------
Summary: PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query is unstable
Key: FLINK-19842
URL:
https://issues.apache.org/jira/browse/FLINK-19842 Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.12.0
Reporter: Robert Metzger
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=8401&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=8d78fe4f-d658-5c70-12f8-4921589024c3{code}
=================================== FAILURES ===================================
_ PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query _
self = <pyflink.table.tests.test_udtf.PyFlinkStreamUserDefinedTableFunctionTests testMethod=test_table_function_with_sql_query>
def test_table_function_with_sql_query(self):
self._register_table_sink(
['a', 'b', 'c'],
[DataTypes.BIGINT(), DataTypes.BIGINT(), DataTypes.BIGINT()])
self.t_env.create_temporary_system_function(
"multi_emit", udtf(MultiEmit(), result_types=[DataTypes.BIGINT(), DataTypes.BIGINT()]))
t = self.t_env.from_elements([(1, 1, 3), (2, 1, 6), (3, 2, 9)], ['a', 'b', 'c'])
self.t_env.register_table("MyTable", t)
t = self.t_env.sql_query(
"SELECT a, x, y FROM MyTable LEFT JOIN LATERAL TABLE(multi_emit(a, b)) as T(x, y)"
" ON TRUE")
actual = self._get_output(t)
> self.assert_equals(actual, ["1,1,0", "2,2,0", "3,3,0", "3,3,1"])
pyflink/table/tests/test_udtf.py:61:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
cls = <class 'pyflink.table.tests.test_udtf.PyFlinkStreamUserDefinedTableFunctionTests'>
actual = JavaObject id=o37759, expected = ['1,1,0', '2,2,0', '3,3,0', '3,3,1']
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
