[test] Limit failure times of SinkSavepointITCase.testRecoverFromSave…

…point
apache · Aug 15, 2024 · e446759 · e446759
1 parent e4d4bdb
commit e446759
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...k/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java b/...k/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java
@@ -69,7 +69,7 @@ public void testRecoverFromSavepoint() throws Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         boolean enableFailure = random.nextBoolean();
         if (enableFailure) {
-            FailingFileIO.reset(failingName, 100, 500);
+            FailingFileIO.reset(failingName, 5, 500);
         } else {
             FailingFileIO.reset(failingName, 0, 1);
         }