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-37493][CORE] show gc time and duration time of driver in executors page #34749
Conversation
should be |
290aabe
to
daa9a65
Compare
core/src/main/scala/org/apache/spark/status/AppStatusStore.scala
Outdated
Show resolved
Hide resolved
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.
Thank you for making a PR, @summaryzb . Since this is UI patch, could you add the screenshots (BEFORE and AFTER) into your PR description?
daa9a65
to
b1559ea
Compare
done as suggested |
Thank you for updates, @summaryzb . |
Maybe we need add new UT or change existing UT tor test incremental code |
1a35643
to
99b61dc
Compare
@srowen @LuciferYang PTAL |
Looks OK to me |
Jenkins test this please |
Kubernetes integration test starting |
Kubernetes integration test status failure |
Test build #145909 has finished for PR 34749 at commit
|
Thank you so much @srowen @LuciferYang @dongjoon-hyun |
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.
Took a pass through the PR, mostly looks good; had a couple of comments.
core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala
Outdated
Show resolved
Hide resolved
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.
Looks good to me.
+CC @thejdeep, @shardulm94
@@ -137,7 +138,9 @@ case object GarbageCollectionMetrics extends ExecutorMetricType with Logging { | |||
|
|||
override private[spark] def getMetricValues(memoryManager: MemoryManager): Array[Long] = { | |||
val gcMetrics = new Array[Long](names.length) // minorCount, minorTime, majorCount, majorTime |
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.
One last thing - should we update or remove this comment? it's missing the 5th name.
No big deal
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.
remove the comment, since it's easy to get the meaning of names
, kind of trouble to update, how about current
cb76126
to
c719048
Compare
c719048
to
b099212
Compare
gentle ping @srowen |
Merged to master |
Congrats on your first contribution, @summaryzb zhoubin ! :) |
Hi @summaryzb Just wonder why the |
This pr aims at showing |
Which |
replace |
Ok, got it now. |
What changes were proposed in this pull request?
show driver's gc time & duration time(equivalent to application time) of driver in both driver side and history side UI
Why are the changes needed?
help user to config driver's resource more appropriately
Does this PR introduce any user-facing change?
yes,user will see driver's gc time & duration time in executors page .
when
spark.eventLog.logStageExecutorMetrics
is enabled driver's gc time can be logged.before this change,user always get zero
How was this patch tested?
unit tests