Skip to content

Commit 00e957c

Browse files
committed
Long line fix.
1 parent ea0edd4 commit 00e957c

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

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

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -190,14 +190,15 @@ trait CheckAnalysis {
190190
| ${exprs.map(_.prettyString).mkString(",")}""".stripMargin)
191191

192192
// Special handling for cases when self-join introduce duplicate expression ids.
193-
case j @ Join(left, right, _, _, _) if left.outputSet.intersect(right.outputSet).nonEmpty =>
194-
val conflictingAttributes = left.outputSet.intersect(right.outputSet)
195-
failAnalysis(
196-
s"""
197-
|Failure when resolving conflicting references in Join:
198-
|$plan
199-
|Conflicting attributes: ${conflictingAttributes.mkString(",")}
200-
|""".stripMargin)
193+
case j @ Join(left, right, _, _, _)
194+
if left.outputSet.intersect(right.outputSet).nonEmpty =>
195+
val conflictingAttributes = left.outputSet.intersect(right.outputSet)
196+
failAnalysis(
197+
s"""
198+
|Failure when resolving conflicting references in Join:
199+
|$plan
200+
|Conflicting attributes: ${conflictingAttributes.mkString(",")}
201+
|""".stripMargin)
201202

202203
case o if !o.resolved =>
203204
failAnalysis(

0 commit comments

Comments
 (0)