Skip to content

Commit e77d62a

Browse files
seancxmaoHyukjinKwon
authored andcommitted
[MINOR][DOCS] Fix comments of SQLExecution#withExecutionId
## What changes were proposed in this pull request? Fix comment. Change `BroadcastHashJoin.broadcastFuture` to `BroadcastExchangeExec.relationFuture`: https://github.com/apache/spark/blob/d28d5732ae205771f1f443b15b10e64dcffb5ff0/sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/BroadcastExchangeExec.scala#L66 ## How was this patch tested? N/A Author: seancxmao <seancxmao@gmail.com> Closes #21113 from seancxmao/SPARK-13136. (cherry picked from commit c303b1b) Signed-off-by: hyukjinkwon <gurwls223@apache.org>
1 parent 041aec4 commit e77d62a

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
@@ -94,7 +94,7 @@ object SQLExecution {
9494
/**
9595
* Wrap an action with a known executionId. When running a different action in a different
9696
* thread from the original one, this method can be used to connect the Spark jobs in this action
97-
* with the known executionId, e.g., `BroadcastHashJoin.broadcastFuture`.
97+
* with the known executionId, e.g., `BroadcastExchangeExec.relationFuture`.
9898
*/
9999
def withExecutionId[T](sc: SparkContext, executionId: String)(body: => T): T = {
100100
val oldExecutionId = sc.getLocalProperty(SQLExecution.EXECUTION_ID_KEY)

0 commit comments

Comments
 (0)