comment

ulysses-you · ulysses-you · commit b5bf37016d16 · 2021-05-14T09:17:59.000+08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala
@@ -328,7 +328,7 @@ class CacheManager extends Logging with AdaptiveSparkPlanHelper {
   }
 
   /**
-   * If CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING is disabled, just return original session.
+   * If CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING is enabled, just return original session.
    */
   private def getOrCloneSessionWithConfigsOff(session: SparkSession): SparkSession = {
     if (session.sessionState.conf.getConf(SQLConf.CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING)) {

Original file line number	Diff line number	Diff line change
`@@ -328,7 +328,7 @@ class CacheManager extends Logging with AdaptiveSparkPlanHelper {`
`328`	`328`	`}`
`329`	`329`
`330`	`330`	`/**`
`331`		`- * If CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING is disabled, just return original session.`
	`331`	`+ * If CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING is enabled, just return original session.`
`332`	`332`	`*/`
`333`	`333`	`private def getOrCloneSessionWithConfigsOff(session: SparkSession): SparkSession = {`
`334`	`334`	`if (session.sessionState.conf.getConf(SQLConf.CAN_CHANGE_CACHED_PLAN_OUTPUT_PARTITIONING)) {`