[
https://issues.apache.org/jira/browse/FLINK-19842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221879#comment-17221879
]
Nicholas Jiang commented on FLINK-19842:
----------------------------------------
cc [~dianfu], [~hxbks2ks]
> 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
> Priority: Major
> Labels: test-stability
>
> 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)
