File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -710,6 +710,7 @@ case class HashShuffleSpec(
710710
711711/**
712712 * [[ShuffleSpec ]] created by [[KeyGroupedPartitioning ]].
713+ *
713714 * @param partitioning key grouped partitioning
714715 * @param distribution distribution
715716 * @param joinKeyPosition position of join keys among cluster keys.
Original file line number Diff line number Diff line change @@ -1533,10 +1533,9 @@ object SQLConf {
15331533 val V2_BUCKETING_ALLOW_JOIN_KEYS_SUBSET_OF_PARTITION_KEYS =
15341534 buildConf(" spark.sql.sources.v2.bucketing.allowJoinKeysSubsetOfPartitionKeys.enabled" )
15351535 .doc(" Whether to allow storage-partition join in the case where join keys are" +
1536- " a subset of the partition keys of the source tables. At planning time, " +
1536+ " a subset of the partition keys of the source tables. At planning time, " +
15371537 " Spark will group the partitions by only those keys that are in the join keys." +
1538- " This is currently enabled only if spark.sql.requireAllClusterKeysForDistribution " +
1539- " is false."
1538+ s " This is currently enabled only if $REQUIRE_ALL_CLUSTER_KEYS_FOR_DISTRIBUTION is false. " +
15401539 )
15411540 .version(" 4.0.0" )
15421541 .booleanConf
You can’t perform that action at this time.
0 commit comments