diff --git a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java index 8dba93bc74..37e2bde90a 100644 --- a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java +++ b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java @@ -546,11 +546,6 @@ public static void updateReconciliationMetadata var lastSpecWithMeta = reconciliationStatus.deserializeLastReconciledSpecWithMeta(); var newMeta = ReconciliationMetadata.from(resource); - if (newMeta.equals(lastSpecWithMeta.getMeta())) { - // Nothing to update - return; - } - reconciliationStatus.setLastReconciledSpec( SpecUtils.writeSpecWithMeta(lastSpecWithMeta.getSpec(), newMeta)); resource.getStatus().setObservedGeneration(resource.getMetadata().getGeneration()); diff --git a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java index 2c236b68cf..34a71d3bcc 100644 --- a/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java +++ b/flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java @@ -1235,10 +1235,6 @@ public void testUpgradeReconciledGeneration() throws Exception { // Submit no-op upgrade deployment.getSpec().getFlinkConfiguration().put("kubernetes.operator.test", "value"); deployment.getMetadata().setGeneration(2L); - deployment - .getStatus() - .getReconciliationStatus() - .serializeAndSetLastReconciledSpec(deployment.getSpec(), deployment); reconciler.reconcile(deployment, context); assertEquals(2L, deployment.getStatus().getObservedGeneration());