Repository: kafka Updated Branches: refs/heads/0.9.0 974e5aa24 -> 20b09694a
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 (cherry picked from commit f3fc9e108eb1e5d47144cc7f2eaa8beb4f88be6b) Signed-off-by: Ewen Cheslack-Postava <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/20b09694 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/20b09694 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/20b09694 Branch: refs/heads/0.9.0 Commit: 20b09694ada7d8393b0628cefa78e3b5c2b3ac21 Parents: 974e5aa 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:25 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/20b09694/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]) {
