apache#9 skip replan those sql which contains window function

xfeep · Sep 19, 2017 · 01a2e50 · 01a2e50
1 parent 4a0f635
commit 01a2e50
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala
@@ -94,6 +94,7 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
       case _ : WindowExec => true
       case _ => plan.children.exists(hasWindowFunction(_))
     }
+    false
   }
 
 
@@ -121,7 +122,7 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
         }) {
           conf.setConf(CBO_ENABLED, true)
         }
-      } else if (hasWindowFunction(plan)) {
+      }/* else if (hasWindowFunction(plan)) {
         Utils.tryWithSafeFinally({
           conf.setConf(JOIN_REORDER_ENABLED, false)
           conf.setConf(JOIN_REORDER_DP_STAR_FILTER, false)
@@ -134,7 +135,8 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
           conf.setConf(JOIN_REORDER_DP_STAR_FILTER, true)
           conf.setConf(STARSCHEMA_DETECTION, true)
         }
-      }
+      } */
+//      logInfo("we get a new plan")
     }
     plan
   }