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