This is an automated email from the ASF dual-hosted git repository.

feiwang pushed a commit to branch branch-1.9
in repository https://gitbox.apache.org/repos/asf/kyuubi.git


The following commit(s) were added to refs/heads/branch-1.9 by this push:
     new a54f33bf18 [KYUUBI #6997][FOLLOWUP] Fix branch-1.9 build issue (#7014)
a54f33bf18 is described below

commit a54f33bf1843667d664e06d17f15ec9a1f0e47a0
Author: Fei Wang <[email protected]>
AuthorDate: Thu Apr 3 17:43:01 2025 -0700

    [KYUUBI #6997][FOLLOWUP] Fix branch-1.9 build issue (#7014)
---
 .../main/scala/org/apache/kyuubi/operation/AbstractOperation.scala    | 2 +-
 .../main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala   | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala
 
b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala
index 4d5db5d4eb..f6e47730f1 100644
--- 
a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala
+++ 
b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala
@@ -103,7 +103,7 @@ abstract class AbstractOperation(session: Session) extends 
Operation with Loggin
 
   protected def setOperationException(opEx: KyuubiSQLException): Unit = {
     this.operationException = opEx
-    withOperationLog(error(s"Error operating $opType: ${opEx.getMessage}", 
opEx))
+    error(s"Error operating $opType: ${opEx.getMessage}", opEx)
   }
 
   def getOperationJobProgress: TProgressUpdateResp = operationJobProgress
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
index f573dc0d2d..cd48d674bc 100644
--- 
a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala
+++ 
b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala
@@ -163,8 +163,8 @@ class BatchJobSubmission(
       opState: OperationState,
       appState: ApplicationState.ApplicationState): 
ApplicationState.ApplicationState = {
     if (opState == OperationState.ERROR && 
!ApplicationState.isTerminated(appState)) {
-      withOperationLog(error(s"Batch $batchId state is $opState," +
-        s" but the application state is $appState and not terminated, set to 
UNKNOWN."))
+      error(s"Batch $batchId state is $opState," +
+        s" but the application state is $appState and not terminated, set to 
UNKNOWN.")
       ApplicationState.UNKNOWN
     } else {
       appState

Reply via email to