You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yux (Jira)" <ji...@apache.org> on 2024/05/07 09:17:00 UTC
[jira] [Created] (FLINK-35304) Mongo ITCase fails due to duplicate records after resuming
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)