kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap
Date Tue, 15 Dec 2015 00:02:22 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b352d7fbf -> f3fc9e108


KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>, Ewen Cheslack-Postava <ewen@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 <jason@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]) {


Mime
View raw message