Xintong Song created FLINK-23790:
------------------------------------
Summary: 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
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)
