Remove query log (#308)

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Apr 17, 2024 · e893123 · e893123
1 parent 9424a79
commit e893123
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala b/spark-sql-application/src/main/scala/org/apache/spark/sql/FlintJobExecutor.scala
@@ -380,7 +380,6 @@ trait FlintJobExecutor {
     val startTime = System.currentTimeMillis()
     // we have to set job group in the same thread that started the query according to spark doc
     spark.sparkContext.setJobGroup(queryId, "Job group for " + queryId, interruptOnCancel = true)
-    logInfo(s"Executing query: $query")
     val result: DataFrame = spark.sql(query)
     // Get Data
     getFormattedData(