You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2018/04/24 08:16:14 UTC
spark git commit: [MINOR][DOCS] Fix comments of
SQLExecution#withExecutionId
Repository: spark
Updated Branches:
refs/heads/master 281c1ca0d -> c303b1b67
[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 <se...@gmail.com>
Closes #21113 from seancxmao/SPARK-13136.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c303b1b6
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c303b1b6
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c303b1b6
Branch: refs/heads/master
Commit: c303b1b6766a3dc5961713f98f62cd7d7ac7972a
Parents: 281c1ca
Author: seancxmao <se...@gmail.com>
Authored: Tue Apr 24 16:16:07 2018 +0800
Committer: hyukjinkwon <gu...@apache.org>
Committed: Tue Apr 24 16:16:07 2018 +0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/sql/execution/SQLExecution.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/c303b1b6/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala
index e991da7..2c5102b 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/SQLExecution.scala
@@ -88,7 +88,7 @@ object SQLExecution {
/**
* Wrap an action with a known executionId. When running a different action in a different
* thread from the original one, this method can be used to connect the Spark jobs in this action
- * with the known executionId, e.g., `BroadcastHashJoin.broadcastFuture`.
+ * with the known executionId, e.g., `BroadcastExchangeExec.relationFuture`.
*/
def withExecutionId[T](sc: SparkContext, executionId: String)(body: => T): T = {
val oldExecutionId = sc.getLocalProperty(SQLExecution.EXECUTION_ID_KEY)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org