[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17472580#comment-17472580 ] Till Rohrmann commented on FLINK-25025: --- Ok, then let's close this ticket as cannot reproduce. > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.3 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17472402#comment-17472402 ] Huang Xingbo commented on FLINK-25025: -- [~trohrmann] The mechanism for sending data asynchronously is controlled by the Apache Beam Portability Framework, not by the PyFlink Operator. Given that this issue hasn't reappeared since 23/Nov/21, I suspect maybe it was fixed by accident while other issues were fixed. So I think the priority of this issue can be reduced. If it recurs again, I will continue to find the root cause. What do you think? > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.3 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17472304#comment-17472304 ] Till Rohrmann commented on FLINK-25025: --- What's the state of this ticket [~hxbks2ks]? > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.3 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(Re
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460610#comment-17460610 ] Till Rohrmann commented on FLINK-25025: --- Thanks for the update [~hxbks2ks]. Do you know the Flink ticket that introduced the asynchronous sending data mechanism? We might want to link to this ticket for easier bookkeeping. > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.3 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.s
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459868#comment-17459868 ] Huang Xingbo commented on FLINK-25025: -- [~trohrmann] I have no way to reproduce this error locally, and I am still analyzing the cause of the possible problem. I guess the problem may be due to the asynchronous sending data mechanism introduced in release-1.14 > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.3 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > No
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458957#comment-17458957 ] Till Rohrmann commented on FLINK-25025: --- Any updates on this ticket [~hxbks2ks]? > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Assignee: Huang Xingbo >Priority: Blocker > Labels: test-stability > Fix For: 1.14.2 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(Referen
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450887#comment-17450887 ] Huang Xingbo commented on FLINK-25025: -- Ok. I will take a look. > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Priority: Blocker > Labels: test-stability > Fix For: 1.14.1 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > Nov 23 04:20:13 at > jav
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449825#comment-17449825 ] Dian Fu commented on FLINK-25025: - [~hxbks2ks] Could you help to take a look at this issue? > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Priority: Blocker > Labels: test-stability > Fix For: 1.14.1 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > Nov 23 0
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449627#comment-17449627 ] Till Rohrmann commented on FLINK-25025: --- cc [~dianfu] > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Priority: Blocker > Labels: test-stability > Fix For: 1.14.1 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > Nov 23 04:20:13 at > java.util.It
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449534#comment-17449534 ] Chesnay Schepler commented on FLINK-25025: -- This fails pretty reliably for me as well :/ > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0, 1.15.0 >Reporter: Till Rohrmann >Priority: Blocker > Labels: test-stability > Fix For: 1.14.1 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) > Nov 23 04:20:13 at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) > No
[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP
[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448477#comment-17448477 ] Till Rohrmann commented on FLINK-25025: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26970&view=logs&j=5cae8624-c7eb-5c51-92d3-4d2dacedd221&t=5acec1b4-945b-59ca-34f8-168928ce5199&l=29370 > BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount > failed on AZP > --- > > Key: FLINK-25025 > URL: https://issues.apache.org/jira/browse/FLINK-25025 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.14.0 >Reporter: Till Rohrmann >Priority: Critical > Labels: test-stability > Fix For: 1.14.1 > > > The test > {{BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount}} > fails on AZP with: > {code} > Nov 23 04:20:13 [ERROR] Tests run: 3, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 0.167 s <<< FAILURE! - in > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest > Nov 23 04:20:13 [ERROR] testFinishBundleTriggeredByCount Time elapsed: 0.068 > s <<< FAILURE! > Nov 23 04:20:13 java.lang.AssertionError: expected:<6> but was:<4> > Nov 23 04:20:13 at org.junit.Assert.fail(Assert.java:89) > Nov 23 04:20:13 at org.junit.Assert.failNotEquals(Assert.java:835) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:647) > Nov 23 04:20:13 at org.junit.Assert.assertEquals(Assert.java:633) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:80) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.util.RowDataHarnessAssertor.assertOutputEquals(RowDataHarnessAssertor.java:60) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.ArrowPythonAggregateFunctionOperatorTestBase.assertOutputEquals(ArrowPythonAggregateFunctionOperatorTestBase.java:62) > Nov 23 04:20:13 at > org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch.BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount(BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.java:206) > Nov 23 04:20:13 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) > Nov 23 04:20:13 at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > Nov 23 04:20:13 at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > Nov 23 04:20:13 at java.lang.reflect.Method.invoke(Method.java:498) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) > Nov 23 04:20:13 at > org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) > Nov 23 04:20:13 at > org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) > Nov 23 04:20:13 at > org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) > Nov 23 04:20:13 at > org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) > Nov 23 04:20:13 at > org.junit.runners.ParentRunner.run(ParentRunner.java:413) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:137) > Nov 23 04:20:13 at org.junit.runner.JUnitCore.run(JUnitCore.java:115) > Nov 23 04:20:13 at > org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43) > Nov 23 04:20:13 at > java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.jav