Skip to content

Commit 0c156f7

Browse files
committed
Address comments
1 parent 0420514 commit 0c156f7

File tree

1 file changed

+3
-2
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical

1 file changed

+3
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/LogicalPlan.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -211,8 +211,9 @@ abstract class UnaryNode extends LogicalPlan {
211211
}
212212

213213
// Equality between aliases for the same expression
214-
aliasMap.values.foreach(_.combinations(2).map {
215-
case Seq(a1, a2) => EqualNullSafe(a1.toAttribute, a2.toAttribute)
214+
aliasMap.values.foreach(_.combinations(2).foreach {
215+
case Seq(a1, a2) =>
216+
allConstraints += EqualNullSafe(a1.toAttribute, a2.toAttribute)
216217
})
217218

218219
/**

0 commit comments

Comments
 (0)