[
https://issues.apache.org/jira/browse/FLINK-37454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-37454:
-------------------------------
Fix Version/s: cdc-3.5.0
(was: cdc-3.4.0)
> Unit Tests (mongodb6) / compile_and_test (8, generic) is not stable
> -------------------------------------------------------------------
>
> Key: FLINK-37454
> URL: https://issues.apache.org/jira/browse/FLINK-37454
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.4.0
> Reporter: Leonard Xu
> Priority: Major
> Fix For: cdc-3.5.0
>
>
> {code:java}
> [INFO]
> Error: Errors:
> Error: test timed out after 500 seconds
> Error: test timed out after 500 seconds
> [INFO]
> Error: Tests run: 128, Failures: 0, Errors: 2, Skipped: 0
> 51m 15s
> at
> com.mongodb.client.internal.ClientSessionBinding.getConnectionSource(ClientSessionBinding.java:128)
> ~[mongodb-driver-sync-4.11.2.jar:?]
> at
> com.mongodb.client.internal.ClientSessionBinding.getReadConnectionSource(ClientSessionBinding.java:92)
> ~[mongodb-driver-sync-4.11.2.jar:?]
> at
> com.mongodb.internal.operation.SyncOperationHelper.withReadConnectionSource(SyncOperationHelper.java:97)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.operation.ChangeStreamBatchCursor.resumeableOperation(ChangeStreamBatchCursor.java:197)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.operation.ChangeStreamBatchCursor.tryNext(ChangeStreamBatchCursor.java:95)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.client.internal.MongoChangeStreamCursorImpl.tryNext(MongoChangeStreamCursorImpl.java:90)
> ~[mongodb-driver-sync-4.11.2.jar:?]
> at
> com.mongodb.kafka.connect.source.StartedMongoSourceTask.getNextBatch(StartedMongoSourceTask.java:594)
> ~[mongo-kafka-connect-1.13.0.jar:?]
> ... 9 more
> 268599 [debezium-engine] ERROR
> org.apache.flink.cdc.debezium.internal.Handover - Reporting error:
> com.mongodb.MongoInterruptedException: Interrupted waiting for lock
> at
> com.mongodb.internal.thread.InterruptionUtil.interruptAndCreateMongoInterruptedException(InterruptionUtil.java:41)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at com.mongodb.internal.Locks.lockInterruptibly(Locks.java:76)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.Locks.checkedWithInterruptibleLock(Locks.java:64)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at com.mongodb.internal.Locks.withInterruptibleLock(Locks.java:59)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at com.mongodb.internal.Locks.withInterruptibleLock(Locks.java:52)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.connection.BaseCluster.withLock(BaseCluster.java:226)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.connection.SingleServerCluster.withLock(SingleServerCluster.java:46)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.connection.BaseCluster.stopWaitQueueHandler(BaseCluster.java:439)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.connection.BaseCluster.close(BaseCluster.java:188)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.internal.connection.SingleServerCluster.close(SingleServerCluster.java:81)
> ~[mongodb-driver-core-4.11.2.jar:?]
> at
> com.mongodb.client.internal.MongoClientDelegate.close(MongoClientDelegate.java:112)
> ~[mongodb-driver-sync-4.11.2.jar:?]
> at
> com.mongodb.client.internal.MongoClientImpl.close(MongoClientImpl.java:156)
> ~[mongodb-driver-sync-4.11.2.jar:?]
> at
> com.mongodb.kafka.connect.source.StartedMongoSourceTask.close(StartedMongoSourceTask.java:353)
> ~[mongo-kafka-connect-1.13.0.jar:?]
> at
> com.mongodb.kafka.connect.source.MongoSourceTask.stop(MongoSourceTask.java:187)
> ~[mongo-kafka-connect-1.13.0.jar:?]
> at
> org.apache.flink.cdc.connectors.mongodb.internal.MongoDBConnectorSourceTask.stop(MongoDBConnectorSourceTask.java:190)
> ~[classes/:?]
> at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:848)
> [debezium-embedded-1.9.8.Final.jar:1.9.8.Final]
> at
> io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:192)
> [debezium-embedded-1.9.8.Final.jar:1.9.8.Final]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> [?:1.8.0_442]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> [?:1.8.0_442]
> at java.lang.Thread.run(Thread.java:750) [?:1.8.0_442]
> Caused by: java.lang.InterruptedException
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1220)
> ~[?:1.8.0_442]
> at
> java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:335)
> ~[?:1.8.0_442]
> at com.mongodb.internal.Locks.lockInterruptibly(Locks.java:74)
> ~[mongodb-driver-core-4.11.2.jar:?]
> ... 18 more
> {code}
> https://github.com/apache/flink-cdc/actions/runs/13780163201/job/38536869516#logs
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
