From 6be209b0a165a685145193d7a59cc8938a448a05 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C2=B7Y?= Date: Wed, 7 Jul 2021 21:19:08 +0800 Subject: [PATCH] NullPointerException may be thrown when the hbase.spark.use.hbasecontext is true --- .../scala/org/apache/hadoop/hbase/spark/DefaultSource.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()