only takes effect when aqe is enabled

nousot · Oct 31, 2023 · 5a2bb6c · 5a2bb6c
1 parent 038b7bb
commit 5a2bb6c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...i-extension-spark-3-5/src/main/scala/org/apache/kyuubi/sql/DynamicShufflePartitions.scala b/...i-extension-spark-3-5/src/main/scala/org/apache/kyuubi/sql/DynamicShufflePartitions.scala
@@ -33,7 +33,7 @@ import org.apache.kyuubi.sql.KyuubiSQLConf.{DYNAMIC_SHUFFLE_PARTITIONS, DYNAMIC_
 case class DynamicShufflePartitions(spark: SparkSession) extends Rule[SparkPlan] {
 
   override def apply(plan: SparkPlan): SparkPlan = {
-    if (!conf.getConf(DYNAMIC_SHUFFLE_PARTITIONS)) {
+    if (!conf.getConf(DYNAMIC_SHUFFLE_PARTITIONS) || !conf.getConf(ADAPTIVE_EXECUTION_ENABLED)) {
       plan
     } else {
       val maxDynamicShufflePartitions = conf.getConf(DYNAMIC_SHUFFLE_PARTITIONS_MAX_NUM)