[
https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415872#comment-17415872
]
Dian Fu commented on FLINK-24305:
---------------------------------
Thanks [~xtsong], [~hxbks2ks] is currently looking into this issue. We suspect
that it's caused by protobuf 3.18.0 which was released today. We are still
confirming that. If this is true, we need to limit the version of protobuf.
> BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure
> -------------------------------------------------------------------------
>
> Key: FLINK-24305
> URL: https://issues.apache.org/jira/browse/FLINK-24305
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.0, 1.12.5, 1.13.2, 1.15.0
> Reporter: Xintong Song
> Assignee: Huang Xingbo
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.14.0, 1.12.6, 1.13.3, 1.15.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24170&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901&l=23011
> {code}
> Sep 15 20:40:43 cls = <class
> 'pyflink.table.tests.test_pandas_udaf.BatchPandasUDAFITTests'>
> Sep 15 20:40:43 actual = JavaObject id=o8666
> Sep 15 20:40:43 expected = ['+I[1, 4.3333335, 13, 5.5, 3.0, 3.0, 4.3333335,
> 8.0, 5.0, 5.0]', '+I[1, 4.3333335, 5, 4.3333335, 3.0, 3.0, 2.5, 4.333....0,
> 4.0, 2.0]', '+I[2, 2.0, 9, 2.0, 4.0, 4.0, 2.0, 2.0, 4.0, 4.0]', '+I[3, 2.0,
> 3, 2.0, 1.0, 1.0, 2.0, 2.0, 1.0, 1.0]']
> Sep 15 20:40:43
> Sep 15 20:40:43 @classmethod
> Sep 15 20:40:43 def assert_equals(cls, actual, expected):
> Sep 15 20:40:43 if isinstance(actual, JavaObject):
> Sep 15 20:40:43 actual_py_list = cls.to_py_list(actual)
> Sep 15 20:40:43 else:
> Sep 15 20:40:43 actual_py_list = actual
> Sep 15 20:40:43 actual_py_list.sort()
> Sep 15 20:40:43 expected.sort()
> Sep 15 20:40:43 assert len(actual_py_list) == len(expected)
> Sep 15 20:40:43 > assert all(x == y for x, y in zip(actual_py_list,
> expected))
> Sep 15 20:40:43 E AssertionError: assert False
> Sep 15 20:40:43 E + where False = all(<generator object
> PyFlinkTestCase.assert_equals.<locals>.<genexpr> at 0x7f792d98b900>)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
