File tree Expand file tree Collapse file tree 2 files changed +9
-2
lines changed
main/scala/org/apache/spark/sql/internal
test/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 2 files changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -556,7 +556,7 @@ object SQLConf {
556
556
.intConf
557
557
.checkValue(_ >= 0 ,
558
558
" The depth of the maximum rewriting conjunction normal form must be positive." )
559
- .createWithDefault(20 )
559
+ .createWithDefault(256 )
560
560
561
561
val ESCAPED_STRING_LITERALS = buildConf(" spark.sql.parser.escapedStringLiterals" )
562
562
.internal()
Original file line number Diff line number Diff line change @@ -1293,7 +1293,14 @@ class FilterPushdownSuite extends PlanTest {
1293
1293
val left = testRelation.where(
1294
1294
(' a === 5 || ' a === 2 || ' a === 1 )).subquery(' x )
1295
1295
val right = testRelation.where(
1296
- (' a >= 2 && ' a <= 3 ) || (' a >= 1 && ' a <= 14 ) || (' a >= 9 && ' a <= 27 )).subquery(' y )
1296
+ (' a >= 2 || ' a >= 1 || ' a >= 9 ) &&
1297
+ (' a >= 2 || ' a >= 1 || ' a <= 27 ) &&
1298
+ (' a >= 2 || ' a <= 14 || ' a >= 9 ) &&
1299
+ (' a >= 2 || ' a <= 14 || ' a <= 27 ) &&
1300
+ (' a <= 3 || ' a >= 1 || ' a >= 9 ) &&
1301
+ (' a <= 3 || ' a >= 1 || ' a <= 27 ) &&
1302
+ (' a <= 3 || ' a <= 14 || ' a >= 9 ) &&
1303
+ (' a <= 3 || ' a <= 14 || ' a <= 27 )).subquery(' y )
1297
1304
val correctAnswer = left.join(right, condition = Some (joinCondition)).analyze
1298
1305
1299
1306
comparePlans(optimized, correctAnswer)
You can’t perform that action at this time.
0 commit comments