Skip to content

Commit

Permalink
[GLUTEN-4194][CORE] Clarify fallback reason when columnar filter is d…
Browse files Browse the repository at this point in the history
…isabled (#4195)
  • Loading branch information
wForget authored Dec 28, 2023
1 parent 0f25b2a commit 2cea5a3
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -435,8 +435,10 @@ case class AddTransformHintRule() extends Rule[SparkPlan] {
case plan: FilterExec =>
val childIsScan = plan.child.isInstanceOf[FileSourceScanExec] ||
plan.child.isInstanceOf[BatchScanExec]
// When scanOnly is enabled, filter after scan will be offloaded.
if ((!scanOnly && !enableColumnarFilter) || (scanOnly && !childIsScan)) {
if (!enableColumnarFilter) {
TransformHints.tagNotTransformable(plan, "columnar Filter is not enabled in FilterExec")
} else if (scanOnly && !childIsScan) {
// When scanOnly is enabled, filter after scan will be offloaded.
TransformHints.tagNotTransformable(
plan,
"ScanOnly enabled and plan child is not Scan in FilterExec")
Expand Down

0 comments on commit 2cea5a3

Please sign in to comment.