-
Notifications
You must be signed in to change notification settings - Fork 28.4k
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-20134][SQL] SQLMetrics.postDriverMetricUpdates to simplify driver side metric updates #17464
Conversation
…ver side metric updates
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.
LGTM except for a minor comment, pending Jenkins.
|
||
SQLMetrics.postDriverMetricUpdates( | ||
sparkContext, | ||
sc.getLocalProperty(SQLExecution.EXECUTION_ID_KEY), |
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.
Should these be used the same variable name, sparkContext
or sc
?
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.
hm for some reason both works. i agree it'd be better to be the same.
Test build #75344 has started for PR 17464 at commit |
Test build #75343 has finished for PR 17464 at commit
|
Merging in master/branch-2.1. |
…ver side metric updates ## What changes were proposed in this pull request? It is not super intuitive how to update SQLMetric on the driver side. This patch introduces a new SQLMetrics.postDriverMetricUpdates function to do that, and adds documentation to make it more obvious. ## How was this patch tested? Updated a test case to use this method. Author: Reynold Xin <[email protected]> Closes #17464 from rxin/SPARK-20134. (cherry picked from commit 9712bd3) Signed-off-by: Reynold Xin <[email protected]>
Test FAILed. |
What changes were proposed in this pull request?
It is not super intuitive how to update SQLMetric on the driver side. This patch introduces a new SQLMetrics.postDriverMetricUpdates function to do that, and adds documentation to make it more obvious.
How was this patch tested?
Updated a test case to use this method.