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)