Skip to content
Snippets Groups Projects
Commit 58072a73 authored by Charles Reiss's avatar Charles Reiss
Browse files

Remove some dead comments

parent 21636ee4
No related branches found
No related tags found
No related merge requests found
...@@ -204,17 +204,11 @@ private[spark] class CacheTracker(actorSystem: ActorSystem, isMaster: Boolean, b ...@@ -204,17 +204,11 @@ private[spark] class CacheTracker(actorSystem: ActorSystem, isMaster: Boolean, b
} }
try { try {
// If we got here, we have to load the split // If we got here, we have to load the split
// Tell the master that we're doing so
//val host = System.getProperty("spark.hostname", Utils.localHostName)
//val future = trackerActor !! AddedToCache(rdd.id, split.index, host)
// TODO: fetch any remote copy of the split that may be available
// TODO: also register a listener for when it unloads
val elements = new ArrayBuffer[Any] val elements = new ArrayBuffer[Any]
logInfo("Computing partition " + split) logInfo("Computing partition " + split)
elements ++= rdd.compute(split, context) elements ++= rdd.compute(split, context)
// Try to put this block in the blockManager // Try to put this block in the blockManager
blockManager.put(key, elements, storageLevel, true) blockManager.put(key, elements, storageLevel, true)
//future.apply() // Wait for the reply from the cache tracker
return elements.iterator.asInstanceOf[Iterator[T]] return elements.iterator.asInstanceOf[Iterator[T]]
} finally { } finally {
loading.synchronized { loading.synchronized {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment