Skip to content
Snippets Groups Projects
Commit 49f19b95 authored by Daoyuan Wang's avatar Daoyuan Wang Committed by Reynold Xin
Browse files

[MINOR] change new Exception to IllegalArgumentException

Author: Daoyuan Wang <daoyuan.wang@intel.com>

Closes #6434 from adrian-wang/joinerr and squashes the following commits:

ee1b64f [Daoyuan Wang] break line
f7c53e9 [Daoyuan Wang] to IllegalArgumentException
f8dea2d [Daoyuan Wang] sys.err to IllegalStateException
be82259 [Daoyuan Wang] change new exception to sys.err
parent 149d1b28
No related branches found
No related tags found
No related merge requests found
...@@ -48,7 +48,8 @@ case class HashOuterJoin( ...@@ -48,7 +48,8 @@ case class HashOuterJoin(
case LeftOuter => left.outputPartitioning case LeftOuter => left.outputPartitioning
case RightOuter => right.outputPartitioning case RightOuter => right.outputPartitioning
case FullOuter => UnknownPartitioning(left.outputPartitioning.numPartitions) case FullOuter => UnknownPartitioning(left.outputPartitioning.numPartitions)
case x => throw new Exception(s"HashOuterJoin should not take $x as the JoinType") case x =>
throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")
} }
override def requiredChildDistribution: Seq[ClusteredDistribution] = override def requiredChildDistribution: Seq[ClusteredDistribution] =
...@@ -63,7 +64,7 @@ case class HashOuterJoin( ...@@ -63,7 +64,7 @@ case class HashOuterJoin(
case FullOuter => case FullOuter =>
left.output.map(_.withNullability(true)) ++ right.output.map(_.withNullability(true)) left.output.map(_.withNullability(true)) ++ right.output.map(_.withNullability(true))
case x => case x =>
throw new Exception(s"HashOuterJoin should not take $x as the JoinType") throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")
} }
} }
...@@ -216,7 +217,8 @@ case class HashOuterJoin( ...@@ -216,7 +217,8 @@ case class HashOuterJoin(
rightHashTable.getOrElse(key, EMPTY_LIST), joinedRow) rightHashTable.getOrElse(key, EMPTY_LIST), joinedRow)
} }
case x => throw new Exception(s"HashOuterJoin should not take $x as the JoinType") case x =>
throw new IllegalArgumentException(s"HashOuterJoin should not take $x as the JoinType")
} }
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment