diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/StatementEvent.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/StatementEvent.scala index d938b718a..f78b8cf51 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/StatementEvent.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/StatementEvent.scala @@ -31,7 +31,7 @@ import org.apache.kyuubi.Utils * @param state: store each state that the sql has * @param stateTime: the time that the sql's state change * @param queryExecution: contains logicPlan and physicalPlan - * @param exeception: caught exeception if have + * @param exception: caught exception if have */ case class StatementEvent( statementId: String, @@ -42,7 +42,7 @@ case class StatementEvent( var state: String, var stateTime: Long, var queryExecution: String = "", - var exeception: String = "") extends KyuubiEvent { + var exception: String = "") extends KyuubiEvent { override def schema: StructType = Encoders.product[StatementEvent].schema override def partitions: Seq[(String, String)] = diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/operation/ExecuteStatement.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/operation/ExecuteStatement.scala index b932acc8c..8d38ab0e2 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/operation/ExecuteStatement.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/operation/ExecuteStatement.scala @@ -175,7 +175,7 @@ class ExecuteStatement( override def setOperationException(opEx: KyuubiSQLException): Unit = { super.setOperationException(opEx) - statementEvent.exeception = opEx.toString + statementEvent.exception = opEx.toString EventLoggingService.onEvent(statementEvent) } }