[flink] branch release-1.16 updated: [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase

[hxb]

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

hxb pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.16 by this push:
     new 8fb13a80390 [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase
8fb13a80390 is described below

commit 8fb13a803904485e0d44ffee8e1510b14543129f
Author: fredia <fredia...@gmail.com>
AuthorDate: Tue Sep 13 14:56:24 2022 +0800

    [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase
    
    This closes #20820.
---
 .../apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java
index acef01c4cb9..57323a811cb 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java
@@ -142,7 +142,6 @@ public class ChangelogLocalRecoveryITCase extends 
TestLogger {
         // wait job for doing materialization.
         waitUntilCondition(
                 () -> !getAllStateHandleId(firstJobGraph.getJobID(), 
miniCluster).isEmpty());
-        miniCluster.triggerCheckpoint(firstJobGraph.getJobID()).get();
         CompletableFuture<Void> terminationFuture = 
miniCluster.terminateTaskManager(1);
         terminationFuture.get();
         miniCluster.startTaskManager();
@@ -165,7 +164,7 @@ public class ChangelogLocalRecoveryITCase extends 
TestLogger {
         env.enableCheckpointing(checkpointInterval);
         env.getCheckpointConfig().enableUnalignedCheckpoints(false);
         env.setStateBackend(stateBackend)
-                .setRestartStrategy(RestartStrategies.fixedDelayRestart(1, 
10));
+                .setRestartStrategy(RestartStrategies.fixedDelayRestart(3, 
10));
         env.configure(new Configuration().set(LOCAL_RECOVERY, true));
 
         env.getCheckpointConfig().setCheckpointStorage(checkpointFile.toURI());