Skip to content

Commit a62e32b

Browse files
committed
Review comments
1 parent 0df6e97 commit a62e32b

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/physical/partitioning.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff 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.

sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)