Skip to content

Commit

Permalink
Update ExpandFallbackPolicy.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer authored Jul 3, 2024
1 parent 84f6935 commit 1ade079
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,8 @@ case class ExpandFallbackPolicy(isAdaptiveContext: Boolean, originalPlan: SparkP
) {
plan
} else {
FallbackTags.addRecursively(vanillaSparkPlan, FallbackTag.Exclusive(fallbackInfo.reason.getOrElse("Unknown reason")))
FallbackTags.addRecursively(
vanillaSparkPlan, FallbackTag.Exclusive(fallbackInfo.reason.getOrElse("Unknown reason")))
FallbackNode(vanillaSparkPlan)
}
} else {
Expand Down

0 comments on commit 1ade079

Please sign in to comment.