Support submit subqueries concurrently, don't trigger subquery execut…

…ion when do native validation
apache · Jun 9, 2023 · ff1e993 · ff1e993
1 parent 75eb94e
commit ff1e993
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/gluten-core/src/main/scala/io/glutenproject/execution/WholeStageTransformer.scala b/gluten-core/src/main/scala/io/glutenproject/execution/WholeStageTransformer.scala
@@ -181,6 +181,9 @@ case class WholeStageTransformer(child: SparkPlan)(val transformStageId: Int)
   }
 
   def doWholestageTransform(): WholestageTransformContext = {
+    // invoke SparkPlan.prepare to do subquery preparation etc.
+    super.prepare()
+
     val substraitContext = new SubstraitContext
     val childCtx = child
       .asInstanceOf[TransformSupport]