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


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

commit 1adcf1e47a7e6ae9908736c3969e2d279a44bc18
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 9f6364743da..16e1854cd27 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
@@ -282,7 +282,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 d0b2bcf8d47..95feb5e3f5c 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));