You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2025/01/14 07:01:39 UTC
(flink) branch release-1.20 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.20 by this push:
new e9c9c40220c [FLINK-37108] Use-non terminal savepoint in source/sink suite
e9c9c40220c is described below
commit e9c9c40220ce4955e15922021a30695e03239caf
Author: Arvid Heise <ar...@apache.org>
AuthorDate: Mon Jan 13 14:26:18 2025 +0100
[FLINK-37108] Use-non terminal savepoint in source/sink suite
---
.../flink/connector/testframe/testsuites/SinkTestSuiteBase.java | 4 +++-
.../flink/connector/testframe/testsuites/SourceTestSuiteBase.java | 2 +-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java b/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java
index 895469d7e83..6e2a1231905 100644
--- a/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java
+++ b/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SinkTestSuiteBase.java
@@ -284,7 +284,9 @@ public abstract class SinkTestSuiteBase<T extends Comparable<T>> {
savepointPath =
jobClient
.stopWithSavepoint(
- true, testEnv.getCheckpointUri(), SavepointFormatType.CANONICAL)
+ false,
+ testEnv.getCheckpointUri(),
+ SavepointFormatType.CANONICAL)
.get(30, TimeUnit.SECONDS);
waitForJobStatus(jobClient, Collections.singletonList(JobStatus.FINISHED));
} catch (Exception e) {
diff --git a/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java b/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java
index acbbd929c9b..840f1f6d93a 100644
--- a/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java
+++ b/flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java
@@ -339,7 +339,7 @@ public abstract class SourceTestSuiteBase<T> {
String savepointPath =
jobClient
.stopWithSavepoint(
- true, testEnv.getCheckpointUri(), SavepointFormatType.CANONICAL)
+ false, testEnv.getCheckpointUri(), SavepointFormatType.CANONICAL)
.get(30, TimeUnit.SECONDS);
waitForJobStatus(jobClient, singletonList(JobStatus.FINISHED));