[
https://issues.apache.org/jira/browse/FLINK-23790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399498#comment-17399498
]
Xintong Song commented on FLINK-23790:
--------------------------------------
cc [~dian.fu] [~Yellow]
> Python test_udtf.py fail on azure
> ---------------------------------
>
> Key: FLINK-23790
> URL: https://issues.apache.org/jira/browse/FLINK-23790
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.0
> Reporter: Xintong Song
> Priority: Major
> Labels: test-stability
> Fix For: 1.14.0
>
>
> 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
> {code}
> 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 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
