From d122877ddc332277aedc111c8b8c40ecd92c70cd Mon Sep 17 00:00:00 2001 From: Jiabao Sun Date: Mon, 14 Mar 2022 22:41:47 +0800 Subject: [PATCH] [mongodb][test] Fix unstable tests of MongoDBConnectorITCase (#944) --- .../connectors/mongodb/table/MongoDBConnectorITCase.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git 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 index dd270fa69..a5c48fb7d 100644 --- 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);