diff --git a/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/DefaultSource.scala b/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/DefaultSource.scala index 84e9123f..e7b6027a 100644 --- a/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/DefaultSource.scala +++ b/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/DefaultSource.scala @@ -127,7 +127,7 @@ case class HBaseRelation ( HBaseSparkConf.BULKGET_SIZE, HBaseSparkConf.DEFAULT_BULKGET_SIZE)) //create or get latest HBaseContext - val hbaseContext:HBaseContext = if (useHBaseContext) { + val hbaseContext:HBaseContext = if (useHBaseContext && LatestHBaseContextCache.latest != null) { LatestHBaseContextCache.latest } else { val config = HBaseConfiguration.create()