You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2015/12/15 01:02:22 UTC
kafka git commit: KAFKA-2990;
Fix NoSuchMethodError in Pool with cast to ConcurrentMap
Repository: kafka
Updated Branches:
refs/heads/trunk b352d7fbf -> f3fc9e108
KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Ismael Juma <is...@juma.me.uk>, Ewen Cheslack-Postava <ew...@confluent.io>
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 <ja...@confluent.io>
Authored: Mon Dec 14 16:02:03 2015 -0800
Committer: Ewen Cheslack-Postava <me...@ewencp.org>
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]) {