Skip to content

Commit 01a2e50

Browse files
committed
apache#9 skip replan those sql which contains window function
1 parent 4a0f635 commit 01a2e50

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
9494
case _ : WindowExec => true
9595
case _ => plan.children.exists(hasWindowFunction(_))
9696
}
97+
false
9798
}
9899

99100

@@ -121,7 +122,7 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
121122
}) {
122123
conf.setConf(CBO_ENABLED, true)
123124
}
124-
} else if (hasWindowFunction(plan)) {
125+
}/* else if (hasWindowFunction(plan)) {
125126
Utils.tryWithSafeFinally({
126127
conf.setConf(JOIN_REORDER_ENABLED, false)
127128
conf.setConf(JOIN_REORDER_DP_STAR_FILTER, false)
@@ -134,7 +135,8 @@ class QueryExecution(val sparkSession: SparkSession, val logical: LogicalPlan) e
134135
conf.setConf(JOIN_REORDER_DP_STAR_FILTER, true)
135136
conf.setConf(STARSCHEMA_DETECTION, true)
136137
}
137-
}
138+
} */
139+
// logInfo("we get a new plan")
138140
}
139141
plan
140142
}

0 commit comments

Comments
 (0)