You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xintong Song (Jira)" <ji...@apache.org> on 2021/08/16 04:44:00 UTC
[jira] [Created] (FLINK-23792) Python test_udf.py fail on azure
Xintong Song created FLINK-23792:
------------------------------------
Summary: Python test_udf.py fail on azure
Key: FLINK-23792
URL: https://issues.apache.org/jira/browse/FLINK-23792
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=ff2e2ea5-07e3-5521-7b04-a4fc3ad765e9&t=1ec6382b-bafe-5817-63ae-eda7d4be718e&l=24542
{code}
Aug 14 23:18:04 =================================== FAILURES ===================================
Aug 14 23:18:04 _______________ PyFlinkStreamUserDefinedFunctionTests.test_open ________________
Aug 14 23:18:04
Aug 14 23:18:04 self = <pyflink.table.tests.test_udf.PyFlinkStreamUserDefinedFunctionTests testMethod=test_open>
Aug 14 23:18:04
Aug 14 23:18:04 def test_open(self):
Aug 14 23:18:04 self.t_env.get_config().get_configuration().set_string('python.metric.enabled', 'true')
Aug 14 23:18:04 subtract = udf(Subtract(), result_type=DataTypes.BIGINT())
Aug 14 23:18:04 table_sink = source_sink_utils.TestAppendSink(
Aug 14 23:18:04 ['a', 'b'], [DataTypes.BIGINT(), DataTypes.BIGINT()])
Aug 14 23:18:04 self.t_env.register_table_sink("Results", table_sink)
Aug 14 23:18:04
Aug 14 23:18:04 t = self.t_env.from_elements([(1, 2), (2, 5), (3, 4)], ['a', 'b'])
Aug 14 23:18:04 > t.select(t.a, subtract(t.b)).execute_insert("Results").wait()
Aug 14 23:18:04
Aug 14 23:18:04 pyflink/table/tests/test_udf.py:226:
Aug 14 23:18:04 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
Aug 14 23:18:04 pyflink/table/table_result.py:76: in wait
Aug 14 23:18:04 get_method(self._j_table_result, "await")()
Aug 14 23:18:04 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1285: in __call__
Aug 14 23:18:04 return_value = get_return_value(
Aug 14 23:18:04 pyflink/util/exceptions.py:146: in deco
Aug 14 23:18:04 return f(*a, **kw)
Aug 14 23:18:04 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)