Skip to content

Commit fb9776e

Browse files
author
nishita-pattanayak
committed
[FLINK-28648][Kubernetes Operator] Addressed minor comments
1 parent 7175b2b commit fb9776e

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -197,22 +197,20 @@ public DeleteControl cleanupInternal(FlinkResourceContext<FlinkDeployment> ctx)
197197
nonTerminalJobs.stream()
198198
.map(JobID::toHexString)
199199
.collect(Collectors.toList()));
200-
if (eventRecorder.triggerEvent(
200+
eventRecorder.triggerEvent(
201201
deployment,
202202
EventRecorder.Type.Warning,
203203
EventRecorder.Reason.CleanupFailed,
204204
EventRecorder.Component.Operator,
205205
error,
206-
ctx.getKubernetesClient())) {
207-
LOG.warn(error);
208-
}
206+
ctx.getKubernetesClient());
209207
return DeleteControl.noFinalizerRemoval()
210208
.rescheduleAfter(ctx.getOperatorConfig().getReconcileInterval().toMillis());
211209
}
212210
}
213211

214212
LOG.info("Stopping session cluster");
215-
var conf = ctx.getDeployConfig(ctx.getResource().getSpec());
213+
var conf = ctx.getObserveConfig();
216214
ctx.getFlinkService()
217215
.deleteClusterDeployment(
218216
deployment.getMetadata(), deployment.getStatus(), conf, true);

0 commit comments

Comments
 (0)