Skip to content

Commit 0b49837

Browse files
committed
delete the annotation
1 parent f1288b4 commit 0b49837

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -236,8 +236,8 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
236236
execution.Limit(limit, planLater(child))(sparkContext) :: Nil
237237
case Unions(unionChildren) =>
238238
execution.Union(unionChildren.map(planLater))(sparkContext) :: Nil
239-
case logical.Intersect(left,right) => //yanjiegaonew
240-
execution.Intersect(planLater(left),planLater(right)) :: Nil //yanjiegaonew
239+
case logical.Intersect(left,right) =>
240+
execution.Intersect(planLater(left),planLater(right)) :: Nil
241241
case logical.Generate(generator, join, outer, _, child) =>
242242
execution.Generate(generator, join = join, outer = outer, planLater(child)) :: Nil
243243
case logical.NoRelation =>

0 commit comments

Comments
 (0)