[
https://issues.apache.org/jira/browse/FLINK-19842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227888#comment-17227888
]
Dian Fu commented on FLINK-19842:
---------------------------------
Seems another instance:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9279&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=8d78fe4f-d658-5c70-12f8-4921589024c3
{code}
2020-11-07T23:17:06.7806808Z self =
<pyflink.table.tests.test_udtf.PyFlinkBlinkStreamUserDefinedFunctionTests
testMethod=test_table_function>
2020-11-07T23:17:06.7807102Z
2020-11-07T23:17:06.7807304Z def test_table_function(self):
2020-11-07T23:17:06.7807580Z self._register_table_sink(
2020-11-07T23:17:06.7807959Z ['a', 'b', 'c'],
2020-11-07T23:17:06.7808316Z [DataTypes.BIGINT(),
DataTypes.BIGINT(), DataTypes.BIGINT()])
2020-11-07T23:17:06.7808665Z
2020-11-07T23:17:06.7808944Z multi_emit = udtf(MultiEmit(),
result_types=[DataTypes.BIGINT(), DataTypes.BIGINT()])
2020-11-07T23:17:06.7809335Z multi_num = udf(MultiNum(),
result_type=DataTypes.BIGINT())
2020-11-07T23:17:06.7809595Z
2020-11-07T23:17:06.7810056Z t = self.t_env.from_elements([(1, 1, 3),
(2, 1, 6), (3, 2, 9)], ['a', 'b', 'c'])
2020-11-07T23:17:06.7810613Z t = t.join_lateral(multi_emit(t.a,
multi_num(t.b)).alias('x', 'y'))
2020-11-07T23:17:06.7811170Z t =
t.left_outer_join_lateral(condition_multi_emit(t.x, t.y).alias('m')) \
2020-11-07T23:17:06.7811479Z .select("x, y, m")
2020-11-07T23:17:06.7812029Z t =
t.left_outer_join_lateral(identity(t.m).alias('n')) \
2020-11-07T23:17:06.7812326Z .select("x, y, n")
2020-11-07T23:17:06.7812560Z actual = self._get_output(t)
2020-11-07T23:17:06.7812820Z self.assert_equals(actual,
2020-11-07T23:17:06.7813237Z ["1,0,null",
"1,1,null", "2,0,null", "2,1,null", "3,0,0", "3,0,1",
2020-11-07T23:17:06.7813628Z > "3,0,2", "3,1,1",
"3,1,2", "3,2,2", "3,3,null"])
{code}
> 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)
