Skip to content

Commit d2da787

Browse files
committed
formatting
1 parent 6a8ecff commit d2da787

File tree

1 file changed

+5
-3
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis

1 file changed

+5
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -971,9 +971,11 @@ class Analyzer(
971971
case j @ Join(left, right, _, _, _) if !j.duplicateResolved =>
972972
j.copy(right = dedupRight(left, right))
973973
case f @ FlatMapCoGroupsInPandas(leftAttributes, rightAttributes, _, _, left, right) =>
974-
val leftAttributes2 = leftAttributes.map(x => resolveExpressionBottomUp(x, left).asInstanceOf[Attribute])
975-
val rightAttributes2 = rightAttributes.map(x => resolveExpressionBottomUp(x, right).asInstanceOf[Attribute])
976-
f.copy(leftAttributes=leftAttributes2, rightAttributes=rightAttributes2)
974+
val leftRes = leftAttributes
975+
.map(x => resolveExpressionBottomUp(x, left).asInstanceOf[Attribute])
976+
val rightRes = rightAttributes
977+
.map(x => resolveExpressionBottomUp(x, right).asInstanceOf[Attribute])
978+
f.copy(leftAttributes = leftRes, rightAttributes = rightRes)
977979
case i @ Intersect(left, right, _) if !i.duplicateResolved =>
978980
i.copy(right = dedupRight(left, right))
979981
case e @ Except(left, right, _) if !e.duplicateResolved =>

0 commit comments

Comments
 (0)