fix

turboFei · turboFei · commit 8409eacacb51 · 2024-11-22T21:03:59.000-08:00
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala
@@ -162,12 +162,13 @@ class BatchJobSubmission(
   }
 
   private def getAppState(
-      operState: OperationState,
+      opState: OperationState,
       appState: ApplicationState.ApplicationState): ApplicationState.ApplicationState = {
-    if (state == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {
+    if (opState == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {
       ApplicationState.UNKNOWN
+    } else {
+      appState
     }
-    appState
   }
 
   override def getOperationLog: Option[OperationLog] = Option(_operationLog)

Original file line number	Diff line number	Diff line change
`@@ -162,12 +162,13 @@ class BatchJobSubmission(`
`162`	`162`	`}`
`163`	`163`
`164`	`164`	`private def getAppState(`
`165`		`- operState: OperationState,`
	`165`	`+ opState: OperationState,`
`166`	`166`	`appState: ApplicationState.ApplicationState): ApplicationState.ApplicationState = {`
`167`		`- if (state == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {`
	`167`	`+ if (opState == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {`
`168`	`168`	`ApplicationState.UNKNOWN`
	`169`	`+ } else {`
	`170`	`+ appState`
`169`	`171`	`}`
`170`		`- appState`
`171`	`172`	`}`
`172`	`173`
`173`	`174`	`override def getOperationLog: Option[OperationLog] = Option(_operationLog)`