Matthias Pohl created FLINK-34115:
-------------------------------------
Summary:
TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate fails
Key: FLINK-34115
URL: https://issues.apache.org/jira/browse/FLINK-34115
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.19.0
Reporter: Matthias Pohl
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56348&view=logs&j=de826397-1924-5900-0034-51895f69d4b7&t=f311e913-93a2-5a37-acab-4a63e1328f94&l=11613]
{code:java}
Jan 14 01:20:01 01:20:01.949 [ERROR] Tests run: 18, Failures: 1, Errors: 0,
Skipped: 0, Time elapsed: 29.07 s <<< FAILURE! -- in
org.apache.flink.table.planner.runtime.stream.table.TableAggregateITCase
Jan 14 01:20:01 01:20:01.949 [ERROR]
org.apache.flink.table.planner.runtime.stream.table.TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate
-- Time elapsed: 0.518 s <<< FAILURE!
Jan 14 01:20:01 org.opentest4j.AssertionFailedError:
Jan 14 01:20:01
Jan 14 01:20:01 expected: List((true,6,1), (false,6,1), (true,6,1), (true,3,2),
(false,6,1), (false,3,2), (true,6,1), (true,5,2), (false,6,1), (false,5,2),
(true,8,1), (true,6,2), (false,8,1), (false,6,2), (true,8,1), (true,6,2))
Jan 14 01:20:01 but was: List((true,3,1), (false,3,1), (true,5,1), (true,3,2),
(false,5,1), (false,3,2), (true,8,1), (true,5,2), (false,8,1), (false,5,2),
(true,8,1), (true,5,2), (false,8,1), (false,5,2), (true,8,1), (true,6,2))
Jan 14 01:20:01 at
sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
Jan 14 01:20:01 at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
Jan 14 01:20:01 at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
Jan 14 01:20:01 at
org.apache.flink.table.planner.runtime.stream.table.TableAggregateITCase.checkRank$1(TableAggregateITCase.scala:122)
Jan 14 01:20:01 at
org.apache.flink.table.planner.runtime.stream.table.TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate(TableAggregateITCase.scala:69)
Jan 14 01:20:01 at java.lang.reflect.Method.invoke(Method.java:498)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
Jan 14 01:20:01 at
java.util.Iterator.forEachRemaining(Iterator.java:116)
Jan 14 01:20:01 at
scala.collection.convert.Wrappers$IteratorWrapper.forEachRemaining(Wrappers.scala:26)
Jan 14 01:20:01 at
java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
Jan 14 01:20:01 at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
Jan 14 01:20:01 at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
Jan 14 01:20:01 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
Jan 14 01:20:01 at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
Jan 14 01:20:01 at
java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
Jan 14 01:20:01 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
Jan 14 01:20:01 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
Jan 14 01:20:01 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
Jan 14 01:20:01 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175){code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
