DBZ-8410 Increase default timeout for records

debezium · Nov 15, 2024 · 70852a5 · 70852a5
1 parent 88208a0
commit 70852a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java b/src/test/java/io/debezium/connector/spanner/AbstractSpannerConnectorIT.java
@@ -66,7 +66,7 @@ public static void after() throws InterruptedException {
     }
 
     public static int waitTimeForRecords() {
-        return Integer.parseInt(System.getProperty(TEST_PROPERTY_PREFIX + "records.waittime", "3"));
+        return Integer.parseInt(System.getProperty(TEST_PROPERTY_PREFIX + "records.waittime", "10"));
     }
 
     protected String getTopicName(Configuration config, String tableName) {