use isTerminated

joaopamaral · joaopamaral · commit 73b77b3f710a · 2024-10-08T14:29:45.000-03: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,7 +162,7 @@ class BatchJobSubmission(
   }
 
   private def getAppState(operState: OperationState, appState: ApplicationState.ApplicationState): ApplicationState.ApplicationState = {
-    if (state == OperationState.ERROR && appState != ApplicationState.FAILED) {
+    if (state == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {
       ApplicationState.UNKNOWN
     }
     appState

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ class BatchJobSubmission(`
`162`	`162`	`}`
`163`	`163`
`164`	`164`	`private def getAppState(operState: OperationState, appState: ApplicationState.ApplicationState): ApplicationState.ApplicationState = {`
`165`		`- if (state == OperationState.ERROR && appState != ApplicationState.FAILED) {`
	`165`	`+ if (state == OperationState.ERROR && !ApplicationState.isTerminated(appState)) {`
`166`	`166`	`ApplicationState.UNKNOWN`
`167`	`167`	`}`
`168`	`168`	`appState`