Skip to content

Commit 21867b8

Browse files
committed
orphaned state snapshot fix
1 parent 12874ee commit 21867b8

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkStateSnapshotController.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,9 @@ public UpdateControl<FlinkStateSnapshot> reconcile(
8989
@Override
9090
public DeleteControl cleanup(
9191
FlinkStateSnapshot flinkStateSnapshot, Context<FlinkStateSnapshot> josdkContext) {
92+
flinkStateSnapshot.setStatus(
93+
Objects.requireNonNullElseGet(
94+
flinkStateSnapshot.getStatus(), FlinkStateSnapshotStatus::new));
9295
var ctx = ctxFactory.getFlinkStateSnapshotContext(flinkStateSnapshot, josdkContext);
9396
try {
9497
metricManager.onRemove(flinkStateSnapshot);
@@ -113,6 +116,8 @@ public DeleteControl cleanup(
113116
@Override
114117
public ErrorStatusUpdateControl<FlinkStateSnapshot> updateErrorStatus(
115118
FlinkStateSnapshot resource, Context<FlinkStateSnapshot> context, Exception e) {
119+
resource.setStatus(
120+
Objects.requireNonNullElseGet(resource.getStatus(), FlinkStateSnapshotStatus::new));
116121
var ctx = ctxFactory.getFlinkStateSnapshotContext(resource, context);
117122
ReconciliationUtils.updateForReconciliationError(ctx, e);
118123

0 commit comments

Comments
 (0)