Skip to content

Commit 17d1094

Browse files
committed
v1 fallback API can support nested predicate pushdown.
1 parent a49b73c commit 17d1094

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2Strategy.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ class DataSourceV2Strategy(session: SparkSession) extends Strategy with Predicat
191191
r.table.asWritable match {
192192
case v1 if v1.supports(TableCapability.V1_BATCH_WRITE) =>
193193
OverwriteByExpressionExecV1(
194-
v1, transferFilters(filters, false), writeOptions.asOptions, query) :: Nil
194+
v1, transferFilters(filters, true), writeOptions.asOptions, query) :: Nil
195195
case v2 =>
196196
OverwriteByExpressionExec(
197197
v2, transferFilters(filters, true), writeOptions.asOptions, planLater(query)) :: Nil

0 commit comments

Comments
 (0)