Fix accidental comment modification.
This commit is contained in:
parent
91a563608e
commit
f1c5eca494
|
@ -185,7 +185,7 @@ private[spark] class MapOutputTracker(conf: SparkConf) extends Logging {
|
||||||
private[spark] class MapOutputTrackerMaster(conf: SparkConf)
|
private[spark] class MapOutputTrackerMaster(conf: SparkConf)
|
||||||
extends MapOutputTracker(conf) {
|
extends MapOutputTracker(conf) {
|
||||||
|
|
||||||
// Cache a serialized version of the output statuses for each shuffle to send them out faster return
|
// Cache a serialized version of the output statuses for each shuffle to send them out faster
|
||||||
private var cacheEpoch = epoch
|
private var cacheEpoch = epoch
|
||||||
private val cachedSerializedStatuses = new TimeStampedHashMap[Int, Array[Byte]]
|
private val cachedSerializedStatuses = new TimeStampedHashMap[Int, Array[Byte]]
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue