trino Flaky TestMongoDynamicFiltering.testJoinDynamicFilteringBlockProbeSide

Error:  io.trino.plugin.mongodb.TestMongoDynamicFiltering.testJoinDynamicFilteringBlockProbeSide -- Time elapsed: 0.802 s <<< FAILURE!
org.opentest4j.AssertionFailedError: 

expected: [1]
 but was: [39]
	at java.base/jdk.internal.reflect.DirectConstructorHandleAccessor.newInstance(DirectConstructorHandleAccessor.java:62)
	at java.base/java.lang.reflect.Constructor.newInstanceWithCaller(Constructor.java:502)
	at io.trino.plugin.mongodb.TestMongoDynamicFiltering.assertDynamicFiltering(TestMongoDynamicFiltering.java:176)
	at io.trino.plugin.mongodb.TestMongoDynamicFiltering.testJoinDynamicFilteringBlockProbeSide(TestMongoDynamicFiltering.java:160)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:194)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:507)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.tryRemoveAndExec(ForkJoinPool.java:1534)
	at java.base/java.util.concurrent.ForkJoinPool.helpJoin(ForkJoinPool.java:2269)
	at java.base/java.util.concurrent.ForkJoinTask.awaitDone(ForkJoinTask.java:495)
	at java.base/java.util.concurrent.ForkJoinTask.join(ForkJoinTask.java:662)
	at java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:194)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:507)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1491)
	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:2073)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:2035)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:187)

https://github.com/trinodb/trino/actions/runs/8837410508/job/24266264851

Apr 26 '24 08:04 ebyhr

I can't reproduce the error on my laptop. Is there any way to rerun the action?

Apr 28 '24 12:04 ZhangJianAo

1/1000 failed on my laptop. Please try @RepeatedTest annotation.

Apr 28 '24 12:04 ebyhr

https://github.com/trinodb/trino/actions/runs/8901798338/job/24446485721

Apr 30 '24 23:04 ebyhr

https://github.com/trinodb/trino/actions/runs/9014196600/job/24766578298?pr=21883

May 09 '24 08:05 ebyhr

https://github.com/trinodb/trino/actions/runs/9122281185/job/25082870737

May 17 '24 03:05 ebyhr

https://github.com/trinodb/trino/actions/runs/9391580264/job/25864189378

Jun 05 '24 22:06 ebyhr

@ZhangJianAo Any updates?

Jun 05 '24 22:06 ebyhr

This test runs the following sql:

SELECT l.comment FROM  lineitem l, part p, orders o WHERE
    l.orderkey = o.orderkey
    AND o.comment = 'nstructions sleep furiously among '
    AND p.partkey = l.partkey
    AND p.comment = 'onic deposits'

Normally there should be two column filters in dynamic filter, one for partkey, another for orderkey.