hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-16638 Reduce the number of Connection's created in classes of hbase-spark module - addendum 2 (Weiqing Yang)
Date Fri, 14 Oct 2016 16:00:54 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 3fe750829 -> 07086036a


HBASE-16638 Reduce the number of Connection's created in classes of hbase-spark module - addendum
2 (Weiqing Yang)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/07086036
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/07086036
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/07086036

Branch: refs/heads/master
Commit: 07086036a5295b79c11fd27e0bc7f6ecfd5129b5
Parents: 3fe7508
Author: tedyu <yuzhihong@gmail.com>
Authored: Fri Oct 14 09:00:38 2016 -0700
Committer: tedyu <yuzhihong@gmail.com>
Committed: Fri Oct 14 09:00:38 2016 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/07086036/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
----------------------------------------------------------------------
diff --git a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
index 066d534..c9edcc4 100644
--- a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
+++ b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
@@ -78,6 +78,9 @@ class HBaseConnectionCacheSuite extends FunSuite with Logging {
 
   def testBasic() {
     HBaseConnectionCache.setTimeout(1 * 1000)
+    HBaseConnectionCache.connectionMap.synchronized {
+      HBaseConnectionCache.connectionMap.clear()
+    }
 
     val connKeyMocker1 = new HBaseConnectionKeyMocker(1)
     val connKeyMocker1a = new HBaseConnectionKeyMocker(1)


Mime
View raw message