Flaky TestMongoDynamicFiltering.testJoinDynamicFilteringBlockProbeSide

[ebyhr]

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

[ZhangJianAo]

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

[ebyhr]

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

[ebyhr]

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

[ebyhr]

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

[ebyhr]

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

[ebyhr]

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

[ebyhr]

@ZhangJianAo Any updates?

[ZhangJianAo]

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.

But sometimes, there is only one column filter in the dynamic filter:

I have noticed the futuresLeft is 1 when there is only one column filter. I am digging to find out why.

[findepi]

https://github.com/trinodb/trino/actions/runs/9463902574/job/26070913235?pr=22302

[ebyhr]

https://github.com/trinodb/trino/actions/runs/10098255060/job/27924965516

[ebyhr]

@ZhangJianAo Could you share the current status?

[ebyhr]

@ZhangJianAo Reminder.

[sopel39]

Found issue, will create PR later