(flink-kubernetes-operator) branch main updated: [hotfix] Fix missing log in AbstractFlinkService

[gyfora]

This is an automated email from the ASF dual-hosted git repository.

gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git


The following commit(s) were added to refs/heads/main by this push:
     new 32808fe9 [hotfix] Fix missing log in AbstractFlinkService
32808fe9 is described below

commit 32808fe9f0a360fc37accbf693388da1ad036324
Author: GuoYu <511955...@qq.com>
AuthorDate: Mon Apr 27 19:59:57 2026 +0800

    [hotfix] Fix missing log in AbstractFlinkService
---
 .../flink/kubernetes/operator/service/AbstractFlinkService.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
index 18fc3690..fbbd871b 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
@@ -730,7 +730,10 @@ public abstract class AbstractFlinkService implements 
FlinkService {
 
             var stats = response.get();
             if (stats == null) {
-                throw new IllegalStateException("Checkpoint ID %d for job %s 
does not exist!");
+                throw new IllegalStateException(
+                        String.format(
+                                "Checkpoint ID %d for job %s does not exist!",
+                                checkpointId, jobId));
             } else if (stats instanceof 
CheckpointStatistics.CompletedCheckpointStatistics) {
                 return CheckpointStatsResult.completed(
                         ((CheckpointStatistics.CompletedCheckpointStatistics) 
stats)