[ 
https://issues.apache.org/jira/browse/FLINK-32348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739477#comment-17739477
 ] 

Martijn Visser commented on FLINK-32348:
----------------------------------------

[~jiabao.sun] It looks like MongoSourceITCase#testRecovery hangs:

{code:java}
"main" #1 prio=5 os_prio=0 tid=0x00007fedb800a800 nid=0xc75 
sleeping[0x00007fedbefd2000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.sleepBeforeRetry(CollectResultFetcher.java:245)
        at 
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:114)
        at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
        at 
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
        at java.util.Iterator.forEachRemaining(Iterator.java:115)
        at 
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122)
        at 
org.apache.flink.connector.mongodb.source.MongoSourceITCase.testRecovery(MongoSourceITCase.java:264)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
{code}

> MongoDB tests are flaky and time out
> ------------------------------------
>
>                 Key: FLINK-32348
>                 URL: https://issues.apache.org/jira/browse/FLINK-32348
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / MongoDB
>            Reporter: Martijn Visser
>            Priority: Critical
>              Labels: test-stability
>
> https://github.com/apache/flink-connector-mongodb/actions/runs/5232649632/jobs/9447519651#step:13:39307



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to