Skip to content

Commit c8adec6

Browse files
committed
fix comments: BroadcastExchange -> BroadcastExchangeExec
1 parent 6aceb43 commit c8adec6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ object SQLExecution {
8888
/**
8989
* Wrap an action with a known executionId. When running a different action in a different
9090
* thread from the original one, this method can be used to connect the Spark jobs in this action
91-
* with the known executionId, e.g., `BroadcastExchange.relationFuture`.
91+
* with the known executionId, e.g., `BroadcastExchangeExec.relationFuture`.
9292
*/
9393
def withExecutionId[T](sc: SparkContext, executionId: String)(body: => T): T = {
9494
val oldExecutionId = sc.getLocalProperty(SQLExecution.EXECUTION_ID_KEY)

0 commit comments

Comments
 (0)