(paimon) branch master updated: [flink] Specify restart strategy for SinkSavepointITCase (#3121)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new efbf5476a [flink] Specify restart strategy for SinkSavepointITCase 
(#3121)
efbf5476a is described below

commit efbf5476a4b14176af0dbd508df63aedf98589f9
Author: tsreaper <tsreape...@gmail.com>
AuthorDate: Fri Mar 29 17:53:07 2024 +0800

    [flink] Specify restart strategy for SinkSavepointITCase (#3121)
---
 .../org/apache/paimon/flink/sink/SinkSavepointITCase.java  | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java
index 8fd1383ff..6d35351d8 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/SinkSavepointITCase.java
@@ -24,6 +24,7 @@ import org.apache.paimon.utils.FailingFileIO;
 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 @@ public class SinkSavepointITCase extends AbstractTestBase {
         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(