Skip to content

Commit f6a539a

Browse files
author
Marcelo Vanzin
committed
Feedback.
1 parent d2c5ed4 commit f6a539a

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

core/src/main/scala/org/apache/spark/status/LiveEntity.scala

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -278,12 +278,14 @@ private class LiveExecutor(val executorId: String, _addTime: Long) extends LiveE
278278
var usedOnHeap = 0L
279279
var usedOffHeap = 0L
280280

281-
// RDD block info. Keeps track of which blocks are stored in this executor, to help with RDD usage
282-
// accounting. This uses nested maps to make it easier to remove information when RDDs are
283-
// unpersisted. First level key is the RDD id, second is the split index.
284-
//
285-
// This is a var so that we can "clear" it and restart with a new map when it becomes empty,
286-
// to save some memory.
281+
/**
282+
* RDD block info. Keeps track of which blocks are stored in this executor, to help with RDD usage
283+
* accounting. This uses nested maps to make it easier to remove information when RDDs are
284+
* unpersisted. First level key is the RDD id, second is the split index.
285+
*
286+
* This is a var so that we can "clear" it and restart with a new map when it becomes empty,
287+
* to save some memory.
288+
*/
287289
private var rddBlockUsage = new OpenHashMap[Int, RDDBlockTracker]()
288290
private var trackedRDDCount = 0
289291

0 commit comments

Comments
 (0)