Skip to content

Commit 07d5c1a

Browse files
author
nishita-pattanayak
committed
[FLINK-28648][Flink-Kubernetes-Operator] Changed getUnManagedJobs -> getNonTerminated + annotated @VisibleForTesting
1 parent ff26986 commit 07d5c1a

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,8 +147,7 @@ Set<JobID> getNonTerminalJobs(FlinkResourceContext<FlinkDeployment> ctx) {
147147
.get()
148148
.getJobs();
149149

150-
// running
151-
// Above terminal states are not considered since they are no longer active jobs
150+
// running job Ids
152151
Set<JobID> nonTerminalJobIds =
153152
allJobs.stream()
154153
.filter(job -> !job.getStatus().isGloballyTerminalState())

0 commit comments

Comments
 (0)