hard code append the FlintPPLSparkExtensions to the spark conf creati…

…on by the FlintREPL Signed-off-by: YANGDB <[email protected]>
YANG-DB · Oct 27, 2023 · b104503 · b104503
1 parent 1f8dda9
commit b104503
Showing 1 changed file with 1 addition 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
@@ -28,7 +28,7 @@ trait FlintJobExecutor {
   def createSparkConf(): SparkConf = {
     new SparkConf()
       .setAppName(getClass.getSimpleName)
-      .set("spark.sql.extensions", "org.opensearch.flint.spark.FlintSparkExtensions")
+      .set("spark.sql.extensions", "org.opensearch.flint.spark.FlintPPLSparkExtensions,org.opensearch.flint.spark.FlintSparkExtensions")
   }
 
   def createSparkSession(conf: SparkConf): SparkSession = {