yux created FLINK-35304:
---------------------------
Summary: Mongo ITCase fails due to duplicate records after resuming
Key: FLINK-35304
URL: https://issues.apache.org/jira/browse/FLINK-35304
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: yux
Test case testRemoveAndAddCollectionsOneByOne keeps failing since downstream
receives duplicate data rows after MongoDB token resume.
2024-05-07T08:57:16.4720998Z [ERROR] Tests run: 20, Failures: 1, Errors: 0,
Skipped: 0, Time elapsed: 498.203 s <<< FAILURE! - in
org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase
2024-05-07T08:57:16.4723517Z [ERROR]
org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase.testRemoveAndAddCollectionsOneByOne
Time elapsed: 38.114 s <<< FAILURE!
2024-05-07T08:57:16.4725419Z java.lang.AssertionError: expected:<33> but
was:<34>
2024-05-07T08:57:16.4726168Z at org.junit.Assert.fail(Assert.java:89)
2024-05-07T08:57:16.4726828Z at
org.junit.Assert.failNotEquals(Assert.java:835)
2024-05-07T08:57:16.4727540Z at
org.junit.Assert.assertEquals(Assert.java:647)
2024-05-07T08:57:16.4728301Z at
org.junit.Assert.assertEquals(Assert.java:633)
2024-05-07T08:57:16.4729698Z at
org.apache.flink.cdc.connectors.mongodb.utils.MongoDBAssertUtils.assertEqualsInOrder(MongoDBAssertUtils.java:118)
2024-05-07T08:57:16.4731863Z at
org.apache.flink.cdc.connectors.mongodb.utils.MongoDBAssertUtils.assertEqualsInAnyOrder(MongoDBAssertUtils.java:111)
2024-05-07T08:57:16.4734296Z at
org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase.testRemoveAndAddCollectionsOneByOne(NewlyAddedTableITCase.java:501)
2024-05-07T08:57:16.4736882Z at
org.apache.flink.cdc.connectors.mongodb.source.NewlyAddedTableITCase.testRemoveAndAddCollectionsOneByOne(NewlyAddedTableITCase.java:330)
2024-05-07T08:57:16.4738847Z at
java.lang.reflect.Method.invoke(Method.java:498)
2024-05-07T08:57:16.4739923Z at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
2024-05-07T08:57:16.4740790Z at java.lang.Thread.run(Thread.java:750)
2024-05-07T08:57:16.4741257Z
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
