Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19582#discussion_r148842854
--- Diff:
core/src/main/scala/org/apache/spark/status/AppStatusListener.scala ---
@@ -528,4 +544,21 @@ private class AppStatusListener(kvstore: KVStore)
extends SparkListener with Log
entity.write(kvstore)
}
+ /** Update a live entity only if it hasn't been updated in the last
configured period. */
+ private def maybeUpdate(entity: LiveEntity): Unit = {
+ if (liveUpdatePeriodNs >= 0) {
+ val now = System.nanoTime()
--- End diff --
I didn't notice that method ever showing up when profiling; my guess is
it's just a read from some CPU register (TSC?) and so reasonably cheap.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
