Leonard Xu created FLINK-37454:
----------------------------------
Summary: 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
Fix For: cdc-3.4.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)
