From 823c14cde46b0d66db491d17cd4b4fa1771f146a Mon Sep 17 00:00:00 2001
From: Jiabao Sun <jiabao.sun@xtransfer.cn>
Date: Fri, 12 Nov 2021 15:33:36 +0800
Subject: [PATCH] [mongo] Fix MongoDBConnectorITCase is timeout on Azure (#600)

---
 .../cdc/connectors/mongodb/table/MongoDBConnectorITCase.java   | 3 +--
 pom.xml                                                        | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

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 faf85f1b0..c7a4761d1 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
@@ -102,8 +102,7 @@ public class MongoDBConnectorITCase extends MongoDBTestBase {
                         + " PRIMARY KEY (name) NOT ENFORCED"
                         + ") WITH ("
                         + " 'connector' = 'values',"
-                        + " 'sink-insert-only' = 'false',"
-                        + " 'sink-expected-messages-num' = '20'"
+                        + " 'sink-insert-only' = 'false'"
                         + ")";
         tEnv.executeSql(sourceDDL);
         tEnv.executeSql(sinkDDL);
diff --git a/pom.xml b/pom.xml
index 51356fda4..2fad89d95 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,7 +66,7 @@ under the License.
     </distributionManagement>
 
     <properties>
-        <flink.version>1.13.1</flink.version>
+        <flink.version>1.13.3</flink.version>
         <debezium.version>1.5.4.Final</debezium.version>
         <geometry.version>2.2.0</geometry.version>
         <testcontainers.version>1.16.2</testcontainers.version>