Fix IT Test

Author: zwangsheng

integration-tests/kyuubi-kubernetes-it/src/test/scala/org/apache/kyuubi/kubernetes/test/spark/SparkOnKubernetesTestsSuite.scala

@@ -208,18 +208,19 @@ class KyuubiOperationKubernetesClusterClusterModeSuite
       batchRequest.getConf.asScala.toMap,
       batchRequest)
 
-    val session = sessionManager.getSession(sessionHandle).asInstanceOf[KyuubiBatchSessionImpl]
-//    val batchJobSubmissionOp = session.batchJobSubmissionOp
+    sessionManager.getSession(sessionHandle).asInstanceOf[KyuubiBatchSessionImpl]
 
     eventually(timeout(3.minutes), interval(50.milliseconds)) {
+      // trigger k8sOperation init here
       val appInfo = k8sOperation.getApplicationInfoByTag(sessionHandle.identifier.toString)
       assert(appInfo.state == RUNNING)
       assert(appInfo.name.startsWith(driverPodNamePrefix))
     }
 
     val killResponse = k8sOperation.killApplicationByTag(sessionHandle.identifier.toString)
     assert(killResponse._1)
-    assert(killResponse._2 startsWith "Operation of deleted appId:")
+    assert(killResponse._2 endsWith "is completed")
+    assert(killResponse._2 contains sessionHandle.identifier.toString)
 
     eventually(timeout(3.minutes), interval(50.milliseconds)) {
       val appInfo = k8sOperation.getApplicationInfoByTag(sessionHandle.identifier.toString)

kyuubi-server/src/main/scala/org/apache/kyuubi/engine/KubernetesApplicationOperation.scala

@@ -87,8 +87,7 @@ class KubernetesApplicationOperation extends ApplicationOperation with Logging {
     debug(s"Deleting application info from Kubernetes cluster by $tag tag")
     try {
       val info = appInfoStore.getOrDefault(tag, ApplicationInfo.notFound)
-      logger.info(appInfoStore.toString)
-      logger.info(info.toMap.toString())
+      debug(s"Application info[tag: ${tag}] is in ${info.state}")
       info.state match {
         case NOT_FOUND | FAILED | UNKNOWN =>
           (
@@ -128,7 +127,7 @@ class KubernetesApplicationOperation extends ApplicationOperation with Logging {
         case NOT_FOUND =>
           ApplicationInfo(id = null, name = null, ApplicationState.NOT_FOUND)
         case _ =>
-          logger.info(s"Successfully got application info by $tag: $info")
+          debug(s"Successfully got application info by $tag: $info")
           info
       }
     } catch {