You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/29 02:30:00 UTC
[jira] [Closed] (FLINK-26880) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure
[ https://issues.apache.org/jira/browse/FLINK-26880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dian Fu closed FLINK-26880.
---------------------------
Resolution: Duplicate
I think it should be the same issue as FLINK-24241. I'm closing this as duplicate.
> PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure
> --------------------------------------------------------------------------------
>
> Key: FLINK-26880
> URL: https://issues.apache.org/jira/browse/FLINK-26880
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.15.0
> Reporter: Yun Gao
> Priority: Major
> Labels: test-stability
>
> {code:java}
> Mar 26 07:08:21 =================================== FAILURES ===================================
> Mar 26 07:08:21 _______ PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition _______
> Mar 26 07:08:21
> Mar 26 07:08:21 self = <pyflink.table.tests.test_udf.PyFlinkStreamUserDefinedFunctionTests testMethod=test_udf_in_join_condition>
> Mar 26 07:08:21
> Mar 26 07:08:21 def test_udf_in_join_condition(self):
> Mar 26 07:08:21 t1 = self.t_env.from_elements([(2, "Hi")], ['a', 'b'])
> Mar 26 07:08:21 t2 = self.t_env.from_elements([(2, "Flink")], ['c', 'd'])
> Mar 26 07:08:21
> Mar 26 07:08:21 f = udf(lambda i: i, result_type=DataTypes.BIGINT())
> Mar 26 07:08:21
> Mar 26 07:08:21 table_sink = source_sink_utils.TestAppendSink(
> Mar 26 07:08:21 ['a', 'b', 'c', 'd'],
> Mar 26 07:08:21 [DataTypes.BIGINT(), DataTypes.STRING(), DataTypes.BIGINT(), DataTypes.STRING()])
> Mar 26 07:08:21 self.t_env.register_table_sink("Results", table_sink)
> Mar 26 07:08:21
> Mar 26 07:08:21 > t1.join(t2).where(f(t1.a) == t2.c).execute_insert("Results").wait()
> Mar 26 07:08:21
> Mar 26 07:08:21 pyflink/table/tests/test_udf.py:104:
> Mar 26 07:08:21 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> Mar 26 07:08:21 pyflink/table/table.py:1083: in execute_insert
> Mar 26 07:08:21 return TableResult(self._j_table.executeInsert(table_path_or_descriptor, overwrite))
> Mar 26 07:08:21 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_gateway.py:1321: in __call__
> Mar 26 07:08:21 return_value = get_return_value(
> Mar 26 07:08:21 pyflink/util/exceptions.py:146: in deco
> Mar 26 07:08:21 return f(*a, **kw)
> Mar 26 07:08:21 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> Mar 26 07:08:21
> Mar 26 07:08:21 answer = 'xro22141'
> Mar 26 07:08:21 gateway_client = <py4j.java_gateway.GatewayClient object at 0x7fcc1a14a1f0>
> Mar 26 07:08:21 target_id = 'o22134', name = 'executeInsert'
> Mar 26 07:08:21
> Mar 26 07:08:21 def get_return_value(answer, gateway_client, target_id=None, name=None):
> Mar 26 07:08:21 """Converts an answer received from the Java gateway into a Python object.
> Mar 26 07:08:21
> Mar 26 07:08:21 For example, string representation of integers are converted to Python
> Mar 26 07:08:21 integer, string representation of objects are converted to JavaObject
> Mar 26 07:08:21 instances, etc.
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33774&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901
--
This message was sent by Atlassian Jira
(v8.20.1#820001)