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 752fe3e47..b932acc8c 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 @@ -91,9 +91,8 @@ class ExecuteStatement( spark.sparkContext.addSparkListener(operationListener) result = spark.sql(statement) // TODO( #921): COMPILED need consider eagerly executed commands - setState(OperationState.COMPILED) statementEvent.queryExecution = result.queryExecution.toString() - EventLoggingService.onEvent(statementEvent) + setState(OperationState.COMPILED) debug(result.queryExecution) iter = new ArrayFetchIterator(result.collect()) setState(OperationState.FINISHED)