chang log

apache · Sep 27, 2023 · 8d9cafb · 8d9cafb
1 parent f270e60
commit 8d9cafb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/scala/org/apache/streampark/flink/client/impl/KubernetesApplicationClientV2.scala b/...rc/main/scala/org/apache/streampark/flink/client/impl/KubernetesApplicationClientV2.scala
@@ -253,10 +253,10 @@ object KubernetesApplicationClientV2 extends KubernetesClientV2Trait with Logger
 
     FlinkK8sOperator.k8sCrOpr.deleteDeployment(namespace, name).runIOAsTry match {
       case Success(_) =>
-        logInfo(richMsg("Shutdown Flink Applicaition successfully."))
         observer.trackedKeys
           .find(_.id == shutDownRequest.id)
           .someOrUnitZIO(key => observer.untrack(key))
+        logInfo(richMsg("Shutdown Flink Applicaition successfully."))
         ShutDownResponse()
       case Failure(err) =>
         logError(richMsg(s"Fail to shutdown Flink Application"), err)