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

This commit is contained in:
tedyu 2016-10-14 09:00:38 -07:00
parent 3fe7508295
commit 07086036a5
1 changed files with 3 additions and 0 deletions

View File

@ -78,6 +78,9 @@ class HBaseConnectionCacheSuite extends FunSuite with Logging {
def testBasic() { def testBasic() {
HBaseConnectionCache.setTimeout(1 * 1000) HBaseConnectionCache.setTimeout(1 * 1000)
HBaseConnectionCache.connectionMap.synchronized {
HBaseConnectionCache.connectionMap.clear()
}
val connKeyMocker1 = new HBaseConnectionKeyMocker(1) val connKeyMocker1 = new HBaseConnectionKeyMocker(1)
val connKeyMocker1a = new HBaseConnectionKeyMocker(1) val connKeyMocker1a = new HBaseConnectionKeyMocker(1)