extend retry from 5 to 20 for tombstone

snowflakedb · Oct 16, 2023 · 6f83ae7 · 6f83ae7
1 parent f87a003
commit 6f83ae7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java b/src/test/java/com/snowflake/kafka/connector/internal/TombstoneRecordIngestionIT.java
@@ -214,8 +214,8 @@ private void testIngestTombstoneRunner(
         this.behavior == SnowflakeSinkConnectorConfig.BehaviorOnNullValues.DEFAULT
             ? sinkRecords.size()
             : 1;
-    TestUtils.assertWithRetry(() -> TestUtils.tableSize(table) == expectedOffset, 10, 5);
+    TestUtils.assertWithRetry(() -> TestUtils.tableSize(table) == expectedOffset, 10, 20);
     TestUtils.assertWithRetry(
-        () -> service.getOffset(new TopicPartition(topic, partition)) == expectedOffset, 10, 5);
+        () -> service.getOffset(new TopicPartition(topic, partition)) == expectedOffset, 10, 20);
   }
 }