Skip to content

Commit 04cfad5

Browse files
author
Robert Kruszewski
committed
correct test
1 parent 47788d8 commit 04cfad5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilterSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1036,7 +1036,7 @@ class ParquetFilterSuite extends QueryTest with ParquetTest with SharedSQLContex
10361036
val filter = s"a in(${Range(0, count).mkString(",")})"
10371037
assert(df.where(filter).count() === count)
10381038
val actual = stripSparkFilter(df.where(filter)).collect().length
1039-
if (pushEnabled && count <= conf.parquetFilterPushDownInFilterThreshold) {
1039+
if (pushEnabled) {
10401040
assert(actual > 1 && actual < data.length)
10411041
} else {
10421042
assert(actual === data.length)

0 commit comments

Comments
 (0)