Skip to content

Commit 7629bf7

Browse files
committed
[SQL] Show better error messages for incorrect join types in DataFrames.
1 parent a8ea096 commit 7629bf7

File tree

1 file changed

+10
-0
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans

1 file changed

+10
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/joinTypes.scala

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,16 @@ object JoinType {
2424
case "leftouter" | "left" => LeftOuter
2525
case "rightouter" | "right" => RightOuter
2626
case "leftsemi" => LeftSemi
27+
case _ =>
28+
val supported = Seq(
29+
"inner",
30+
"outer", "full", "fullouter",
31+
"leftouter", "left",
32+
"rightouter", "right",
33+
"leftsemi")
34+
35+
throw new IllegalArgumentException(s"Unsupported join type '$typ'. " +
36+
"Supported join types include: " + supported.mkString("'", "', '", "'") + ".")
2737
}
2838
}
2939

0 commit comments

Comments
 (0)