[flink] Specify restart strategy for SinkSavepointITCase (#3121)

apache · Mar 29, 2024 · efbf547 · efbf547
1 parent 0d91a85
commit efbf547
Showing 1 changed file with 14 additions and 0 deletions.
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
@@ -24,6 +24,7 @@
 import org.apache.flink.api.common.JobStatus;
 import org.apache.flink.configuration.CheckpointingOptions;
 import org.apache.flink.configuration.Configuration;
+import org.apache.flink.configuration.RestartStrategyOptions;
 import org.apache.flink.configuration.StateBackendOptions;
 import org.apache.flink.core.execution.JobClient;
 import org.apache.flink.core.execution.SavepointFormatType;
@@ -149,6 +150,19 @@ private JobClient runRecoverFromSavepointJob(String failingPath, String savepoin
         tEnv.getConfig()
                 .getConfiguration()
                 .set(ExecutionConfigOptions.TABLE_EXEC_RESOURCE_DEFAULT_PARALLELISM, 1);
+        tEnv.getConfig()
+                .getConfiguration()
+                .set(RestartStrategyOptions.RESTART_STRATEGY, "fixed-delay");
+        tEnv.getConfig()
+                .getConfiguration()
+                .set(
+                        RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS,
+                        Integer.MAX_VALUE);
+        tEnv.getConfig()
+                .getConfiguration()
+                .set(
+                        RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY,
+                        Duration.ofSeconds(1));
 
         String createCatalogSql =
                 String.join(