Skip to content

Commit

Permalink
SPARK-7729: review comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
archit.thakur committed Nov 5, 2015
1 parent 050e949 commit cc387cd
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package org.apache.spark.storage

import java.util.concurrent.TimeUnit

import scala.collection.JavaConversions.collectionAsScalaIterable
import scala.collection.JavaConverters.collectionAsScalaIterableConverter
import scala.collection.mutable
import scala.language.reflectiveCalls

Expand Down Expand Up @@ -63,7 +63,7 @@ class StorageStatusListener(conf: SparkConf) extends SparkListener {
}

def removedExecutorStorageStatusList: Seq[StorageStatus] = synchronized{
removedExecutorIdToStorageStatus.asMap().values().toSeq
removedExecutorIdToStorageStatus.asMap().values().asScala.toSeq
}

/** Update storage status list to reflect updated block statuses */
Expand Down

0 comments on commit cc387cd

Please sign in to comment.