[mongodb][test] Fix unstable tests of MongoDBConnectorITCase (#944)

3 years ago · d122877ddc
parent 2a704e551c
commit d122877ddc
1 changed files with 6 additions and 0 deletions
--- a/flink-connector-mongodb-cdc/src/test/java/com/ververica/cdc/connectors/mongodb/table/MongoDBConnectorITCase.java
+++ b/flink-connector-mongodb-cdc/src/test/java/com/ververica/cdc/connectors/mongodb/table/MongoDBConnectorITCase.java
@ -146,6 +146,9 @@ public class MongoDBConnectorITCase extends MongoDBTestBase {
                Filters.eq("_id", new ObjectId("100000000000000000000111")),
                Updates.set("weight", 5.17));

+        // Delay delete operations to avoid unstable tests.
+        waitForSinkSize("sink", 19);
+
        products.deleteOne(Filters.eq("_id", new ObjectId("100000000000000000000111")));

        waitForSinkSize("sink", 20);
@ -438,6 +441,9 @@ public class MongoDBConnectorITCase extends MongoDBTestBase {
                Filters.eq("_id", new ObjectId("100000000000000000000111")),
                Updates.set("weight", 5.17));

+        // Delay delete operations to avoid unstable tests.
+        waitForSinkSize("meta_sink", 15);
+
        products.deleteOne(Filters.eq("_id", new ObjectId("100000000000000000000111")));

        waitForSinkSize("meta_sink", 16);