From e624e7b8f708673aee124d823e2ad4a7b7a17b76 Mon Sep 17 00:00:00 2001 From: hongdongdong Date: Wed, 25 Aug 2021 15:29:15 +0800 Subject: [PATCH] [KYUUBI #982] Fix the typo issue ### _Why are the changes needed?_ Fix the typo issue ### _How was this patch tested?_ - [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible - [ ] Add screenshots for manual tests if appropriate - [X] [Run test](https://kyuubi.readthedocs.io/en/latest/develop_tools/testing.html#running-tests) locally before make a pull request Closes #982 from hddong/fix-typo-issue. Closes #982 d6f6315d [hongdongdong] Fix the typo issue Authored-by: hongdongdong Signed-off-by: ulysses-you --- .../apache/kyuubi/engine/spark/events/StatementEvent.scala | 4 ++-- .../kyuubi/engine/spark/operation/ExecuteStatement.scala | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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) } }