New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-30213][SQL] Remove the mutable status in ShuffleQueryStageExec #26846
Conversation
… to ShuffleExchangeExec
Please help to retest. Thanks. |
Test build #115152 has finished for PR 26846 at commit
|
@@ -64,6 +66,14 @@ case class ShuffleExchangeExec( | |||
|
|||
@transient lazy val inputRDD: RDD[InternalRow] = child.execute() | |||
|
|||
@transient lazy val mapOutputStatisticsFuture: Future[MapOutputStatistics] = { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can we add a comment saying that this is only needed in AQE?
retest this please |
Test build #115160 has finished for PR 26846 at commit
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1, LGTM (with +1 for @cloud-fan 's comment).
@cloud-fan @dongjoon-hyun add the comments. Thanks |
Merged to master. (The last commit is only adding a comment.) |
Test build #115205 has finished for PR 26846 at commit
|
What changes were proposed in this pull request?
Currently
ShuffleQueryStageExec
contain the mutable status, egmapOutputStatisticsFuture
variable. So It is not easy to pass when we copyShuffleQueryStageExec
. This PR will put themapOutputStatisticsFuture
variable fromShuffleQueryStageExec
toShuffleExchangeExec
. And then we can pass the value ofmapOutputStatisticsFuture
when copying.Why are the changes needed?
In order to remove the mutable status in
ShuffleQueryStageExec
Does this PR introduce any user-facing change?
No
How was this patch tested?
Existing uts