Repository: kafka Updated Branches: refs/heads/trunk b352d7fbf -> f3fc9e108
KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap Author: Jason Gustafson <[email protected]> Reviewers: Ismael Juma <[email protected]>, Ewen Cheslack-Postava <[email protected]> Closes #675 from hachikuji/KAFKA-2990 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f3fc9e10 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f3fc9e10 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f3fc9e10 Branch: refs/heads/trunk Commit: f3fc9e108eb1e5d47144cc7f2eaa8beb4f88be6b Parents: b352d7f Author: Jason Gustafson <[email protected]> Authored: Mon Dec 14 16:02:03 2015 -0800 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Mon Dec 14 16:02:03 2015 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/utils/Pool.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/f3fc9e10/core/src/main/scala/kafka/utils/Pool.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/utils/Pool.scala b/core/src/main/scala/kafka/utils/Pool.scala index beeab0f..f4aa628 100644 --- a/core/src/main/scala/kafka/utils/Pool.scala +++ b/core/src/main/scala/kafka/utils/Pool.scala @@ -22,12 +22,10 @@ import java.util.concurrent._ import collection.mutable import collection.JavaConversions import kafka.common.KafkaException -import java.lang.Object - class Pool[K,V](valueFactory: Option[(K) => V] = None) extends Iterable[(K, V)] { - private val pool = new ConcurrentHashMap[K, V] + private val pool: ConcurrentMap[K, V] = new ConcurrentHashMap[K, V] private val createLock = new Object def this(m: collection.Map[K, V]) {
