(flink) branch release-1.19 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.19
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.19 by this push:
     new 2e9c06d3a9b [FLINK-37108] Use-non terminal savepoint in source/sink 
suite
2e9c06d3a9b is described below

commit 2e9c06d3a9b1a1b6b9c7e73f0fab9364255db6a5
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 2fe57682f2c..aad60cff93c 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
@@ -283,7 +283,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 7f5f0d3013a..5e4ba2dcca2 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
@@ -338,7 +338,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));