diff --git a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/events/EventLoggingServiceSuite.scala b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/events/EventLoggingServiceSuite.scala index 8d912a30e..ae72b9db3 100644 --- a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/events/EventLoggingServiceSuite.scala +++ b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/events/EventLoggingServiceSuite.scala @@ -94,7 +94,7 @@ class EventLoggingServiceSuite extends WithSparkSQLEngine with JDBCTestUtils { test("statementEvent: generate, dump and query") { val statementEventPath = Paths.get( - logRoot.toString, "spark-statement", s"day=$currentDate", engine.engineId + ".json") + logRoot.toString, "spark_statement", s"day=$currentDate", engine.engineId + ".json") val sql = "select timestamp'2021-06-01'" withSessionHandle { (client, handle) => diff --git a/kyuubi-common/src/main/scala/org/apache/kyuubi/events/KyuubiEvent.scala b/kyuubi-common/src/main/scala/org/apache/kyuubi/events/KyuubiEvent.scala index 39a59c573..24aa75b20 100644 --- a/kyuubi-common/src/main/scala/org/apache/kyuubi/events/KyuubiEvent.scala +++ b/kyuubi-common/src/main/scala/org/apache/kyuubi/events/KyuubiEvent.scala @@ -22,7 +22,7 @@ import java.util.Locale trait KyuubiEvent extends Product { final lazy val eventType: String = { this.getClass.getSimpleName.stripSuffix("Event") - .replaceAll("(.)([A-Z])", "$1-$2") + .replaceAll("(.)([A-Z])", "$1_$2") .toLowerCase(Locale.ROOT) } diff --git a/kyuubi-server/src/test/scala/org/apache/kyuubi/events/EventLoggingServiceSuite.scala b/kyuubi-server/src/test/scala/org/apache/kyuubi/events/EventLoggingServiceSuite.scala index b8ea732eb..c38e5e533 100644 --- a/kyuubi-server/src/test/scala/org/apache/kyuubi/events/EventLoggingServiceSuite.scala +++ b/kyuubi-server/src/test/scala/org/apache/kyuubi/events/EventLoggingServiceSuite.scala @@ -43,9 +43,9 @@ class EventLoggingServiceSuite extends WithKyuubiServer with JDBCTestUtils { test("statementEvent: generate, dump and query") { val hostName = InetAddress.getLocalHost.getCanonicalHostName val serverStatementEventPath = - Paths.get(logRoot.toString, "kyuubi-statement", s"day=$currentDate", s"server-$hostName.json") + Paths.get(logRoot.toString, "kyuubi_statement", s"day=$currentDate", s"server-$hostName.json") val engineStatementEventPath = - Paths.get(logRoot.toString, "spark-statement", s"day=$currentDate", "*.json") + Paths.get(logRoot.toString, "spark_statement", s"day=$currentDate", "*.json") val sql = "select timestamp'2021-06-01'" withJdbcStatement() { statement =>