Oops, fix compile error

apache · Mar 14, 2017 · 5da4bcffa1b39ea8c83fe63a09e68297be371784 · 5da4bcf
1 parent 27234e1
commit 5da4bcffa1b39ea8c83fe63a09e68297be371784
Unified Split

Showing with 1 addition and 1 deletion.

+1 −1 core/src/main/scala/org/apache/spark/storage/BlockInfoManager.scala
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockInfoManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockInfoManager.scala
@@ -340,7 +340,7 @@ private[storage] class BlockInfoManager extends Logging {
     val blocksWithReleasedLocks = mutable.ArrayBuffer[BlockId]()
 
     val readLocks = synchronized {
-      readLocksByTask.remove(taskAttemptId).getOrElse(ImmutableMultiset.of())
+      readLocksByTask.remove(taskAttemptId).getOrElse(ImmutableMultiset.of[BlockId]())
     }
     val writeLocks = synchronized {
       writeLocksByTask.remove(taskAttemptId).getOrElse(Seq.empty)