Fix to #154 (CacheTracker trying to cast a broadcast variable's ID to int)
This commit is contained in:
parent
c0d5bd6553
commit
508221b8e6
|
@ -225,9 +225,10 @@ class CacheTracker(isMaster: Boolean, theCache: Cache) extends Logging {
|
||||||
|
|
||||||
// Called by the Cache to report that an entry has been dropped from it
|
// Called by the Cache to report that an entry has been dropped from it
|
||||||
def dropEntry(datasetId: Any, partition: Int) {
|
def dropEntry(datasetId: Any, partition: Int) {
|
||||||
datasetId match {
|
val (keySpaceId, innerId) = datasetId.asInstanceOf[(Any, Any)]
|
||||||
//TODO - do we really want to use '!!' when nobody checks returned future? '!' seems to enough here.
|
if (keySpaceId == cache.keySpaceId) {
|
||||||
case (cache.keySpaceId, rddId: Int) => trackerActor !! DroppedFromCache(rddId, partition, Utils.getHost)
|
// TODO - do we really want to use '!!' when nobody checks returned future? '!' seems to enough here.
|
||||||
|
trackerActor !! DroppedFromCache(innerId.asInstanceOf[Int], partition, Utils.getHost)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue