You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kyuubi.apache.org by fe...@apache.org on 2025/04/04 00:43:06 UTC
(kyuubi) branch branch-1.9 updated: [KYUUBI #6997][FOLLOWUP] Fix branch-1.9 build issue (#7014)
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 <fw...@ebay.com>
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