Skip to content

Commit 7b20049

Browse files
committed
Address comments in unit test and rebase
1 parent 2e9aff9 commit 7b20049

File tree

2 files changed

+1
-18
lines changed

2 files changed

+1
-18
lines changed

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

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -2661,18 +2661,6 @@ object SQLConf {
26612661
.checkValue(_ > 0, "The difference must be positive.")
26622662
.createWithDefault(4)
26632663

2664-
val COALESCE_BUCKETS_IN_SHUFFLED_HASH_JOIN_MAX_BUCKET_RATIO =
2665-
buildConf("spark.sql.bucketing.coalesceBucketsInShuffledHashJoin.maxBucketRatio")
2666-
.doc("The ratio of the number of two buckets being coalesced should be less than or " +
2667-
"equal to this value for bucket coalescing to be applied. This configuration only " +
2668-
s"has an effect when '${COALESCE_BUCKETS_IN_JOIN_ENABLED.key}' is set to true. " +
2669-
"Note as coalescing reduces parallelism, there might be a higher risk for " +
2670-
"out of memory error at shuffled hash join build side.")
2671-
.version("3.1.0")
2672-
.intConf
2673-
.checkValue(_ > 0, "The difference must be positive.")
2674-
.createWithDefault(2)
2675-
26762664
val BROADCAST_HASH_JOIN_OUTPUT_PARTITIONING_EXPAND_LIMIT =
26772665
buildConf("spark.sql.execution.broadcastHashJoin.outputPartitioningExpandLimit")
26782666
.internal()
@@ -2683,7 +2671,7 @@ object SQLConf {
26832671
.intConf
26842672
.checkValue(_ >= 0, "The value must be non-negative.")
26852673
.createWithDefault(8)
2686-
2674+
26872675
/**
26882676
* Holds information about keys that have been deprecated.
26892677
*

sql/core/src/test/scala/org/apache/spark/sql/execution/bucketing/CoalesceBucketsInJoinSuite.scala

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -128,16 +128,11 @@ class CoalesceBucketsInJoinSuite extends SQLTestUtils with SharedSparkSession {
128128
}
129129

130130
withSQLConf(SQLConf.COALESCE_BUCKETS_IN_JOIN_ENABLED.key -> "false") {
131-
run(JoinSetting(
132-
RelationSetting(4, None), RelationSetting(8, None), joinOperator = BROADCAST_HASH_JOIN))
133131
run(JoinSetting(
134132
RelationSetting(4, None), RelationSetting(8, None), joinOperator = SORT_MERGE_JOIN))
135133
run(JoinSetting(
136134
RelationSetting(4, None), RelationSetting(8, None), joinOperator = SHUFFLED_HASH_JOIN,
137135
shjBuildSide = Some(BuildLeft)))
138-
run(JoinSetting(
139-
RelationSetting(4, None), RelationSetting(8, None), joinOperator = SHUFFLED_HASH_JOIN,
140-
shjBuildSide = Some(BuildRight)))
141136
}
142137
}
143138

0 commit comments

Comments
 (0)