From 1d42d0ba6386f65d1b6f2da77becadfda031cbbd Mon Sep 17 00:00:00 2001 From: "caizhi.wcz" Date: Fri, 29 Mar 2024 17:11:14 +0800 Subject: [PATCH] [flink] Specify restart strategy for SinkSavepointITCase --- .../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 8fd1383ffb72..6d35351d87c0 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.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(