This is an automated email from the ASF dual-hosted git repository. leonardBang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit b294f92da78cec3055270f9e8a33a1acd218009c Author: Leonard Xu <[email protected]> AuthorDate: Wed Jul 1 14:57:44 2026 +0800 [test][pipeline-postgres] Avoid canceling stopped savepoint jobs --- .../flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java index f45209169..3a67acca3 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresPipelineITCase.java @@ -233,11 +233,10 @@ public class PostgresPipelineITCase extends PostgresTestBase { // Wait for the pipeline to process the insert events Thread.sleep(5000); - // Trigger a savepoint and cancel the job + // Trigger a savepoint and stop the job with that savepoint LOG.info("Triggering savepoint"); finishedSavePointPath = triggerSavepointWithRetry(jobClient, savepointDirectory); LOG.info("Savepoint created at: {}", finishedSavePointPath); - jobClient.cancel().get(); iterator.close(); // Restore from savepoint
