[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xintong Song updated FLINK-24305: --------------------------------- Priority: Blocker (was: Major) > 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.15.0 > Reporter: Xintong Song > Priority: Blocker > Labels: test-stability > Fix For: 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)