We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 47788d8 commit 04cfad5Copy full SHA for 04cfad5
sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilterSuite.scala
@@ -1036,7 +1036,7 @@ class ParquetFilterSuite extends QueryTest with ParquetTest with SharedSQLContex
1036
val filter = s"a in(${Range(0, count).mkString(",")})"
1037
assert(df.where(filter).count() === count)
1038
val actual = stripSparkFilter(df.where(filter)).collect().length
1039
- if (pushEnabled && count <= conf.parquetFilterPushDownInFilterThreshold) {
+ if (pushEnabled) {
1040
assert(actual > 1 && actual < data.length)
1041
} else {
1042
assert(actual === data.length)
0 commit comments