You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2023/02/20 14:33:09 UTC
[flink] branch release-1.17 updated: [FLINK-31036][test][checkpoint] FileSystemCheckpointStorage as the default for test
This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.17 by this push:
new ae53a8de47b [FLINK-31036][test][checkpoint] FileSystemCheckpointStorage as the default for test
ae53a8de47b is described below
commit ae53a8de47b31e248fef216428a83c8bf3f07b13
Author: 1996fanrui <19...@gmail.com>
AuthorDate: Fri Feb 17 21:10:52 2023 +0800
[FLINK-31036][test][checkpoint] FileSystemCheckpointStorage as the default for test
---
.../org/apache/flink/runtime/testutils/MiniClusterResource.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
index ba609183f1c..5282f8acb39 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
@@ -18,6 +18,7 @@
package org.apache.flink.runtime.testutils;
+import org.apache.flink.configuration.CheckpointingOptions;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.CoreOptions;
import org.apache.flink.configuration.HeartbeatManagerOptions;
@@ -199,6 +200,14 @@ public class MiniClusterResource extends ExternalResource {
new Configuration(miniClusterResourceConfiguration.getConfiguration());
configuration.setString(
CoreOptions.TMP_DIRS, temporaryFolder.newFolder().getAbsolutePath());
+ if (!configuration.contains(CheckpointingOptions.CHECKPOINTS_DIRECTORY)) {
+ // The channel state or checkpoint file may exceed the upper limit of
+ // JobManagerCheckpointStorage, so use FileSystemCheckpointStorage as
+ // the default checkpoint storage for all tests.
+ configuration.set(
+ CheckpointingOptions.CHECKPOINTS_DIRECTORY,
+ temporaryFolder.newFolder().toURI().toString());
+ }
// we need to set this since a lot of test expect this because TestBaseUtils.startCluster()
// enabled this by default