Skip to content

Commit f7bca2f

Browse files
committed
BroardCast hint can not work with PruneFileSourcePartitions
1 parent 270916f commit f7bca2f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,12 @@ package org.apache.spark.sql.execution.datasources
2020
import org.apache.spark.sql.catalyst.catalog.CatalogStatistics
2121
import org.apache.spark.sql.catalyst.expressions._
2222
import org.apache.spark.sql.catalyst.planning.PhysicalOperation
23-
import org.apache.spark.sql.catalyst.plans.logical.{Filter, LogicalPlan, Project}
23+
import org.apache.spark.sql.catalyst.plans.logical.{Filter, LogicalPlan, Project, ResolvedHint}
2424
import org.apache.spark.sql.catalyst.rules.Rule
2525

2626
private[sql] object PruneFileSourcePartitions extends Rule[LogicalPlan] {
2727
override def apply(plan: LogicalPlan): LogicalPlan = plan transformDown {
28+
case h: ResolvedHint => h
2829
case op @ PhysicalOperation(projects, filters,
2930
logicalRelation @
3031
LogicalRelation(fsRelation @

0 commit comments

Comments
 (0)