Skip to content

Commit

Permalink
Fix scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
viirya committed Apr 4, 2024
1 parent 96b4aa4 commit 778466a
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -119,11 +119,11 @@ case class CometBroadcastExchangeExec(originalPlan: SparkPlan, child: SparkPlan)
CometExec.getByteArrayRdd(s.plan.asInstanceOf[CometPlan]).collect()
case AQEShuffleReadExec(s: ShuffleQueryStageExec, _) =>
throw new CometRuntimeException(
s"Child of CometBroadcastExchangeExec should be CometExec, " +
"Child of CometBroadcastExchangeExec should be CometExec, " +
s"but got: ${s.plan.getClass}")
case _ =>
throw new CometRuntimeException(
s"Child of CometBroadcastExchangeExec should be CometExec, " +
"Child of CometBroadcastExchangeExec should be CometExec, " +
s"but got: ${child.getClass}")
}

Expand Down

0 comments on commit 778466a

Please sign in to comment.