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 295184b commit b15e895Copy full SHA for b15e895
core/src/test/scala/org/apache/spark/sql/delta/stats/DataSkippingDeltaTests.scala
@@ -1524,7 +1524,8 @@ trait DataSkippingDeltaTestsBase extends QueryTest
1524
sql(s"SELECT nested.b FROM delta.`$dir` WHERE nested.b < 2").collect()
1525
}
1526
val rddScans = plans.flatMap(_.collect {
1527
- case l: LogicalRDD => l
+ // Only look for the RDD containg the path, ignore the initial cached RDD for all AddFile's
1528
+ case l: LogicalRDD if l.output.exists(_.name == "path") => l
1529
})
1530
// We should only scan the log once
1531
assert(rddScans.length == 1)
0 commit comments