(flink) branch release-1.20 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite

[arvid]

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));