diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkContextHelper.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkContextHelper.scala index dd10718a8c0..667bd984af8 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkContextHelper.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/SparkContextHelper.scala @@ -38,6 +38,6 @@ object SparkContextHelper { */ private class SparkHistoryEventLogger(sc: SparkContext) extends EventLogger[KyuubiSparkEvent] { override def logEvent(kyuubiEvent: KyuubiSparkEvent): Unit = { - sc.eventLogger.foreach(_.onOtherEvent(kyuubiEvent)) + sc.listenerBus.post(kyuubiEvent) } }