[
https://issues.apache.org/jira/browse/FLINK-23792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-23792.
---------------------------
Resolution: Not A Bug
> 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
> Assignee: Huang Xingbo
> 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=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)
