Transient binarySearch function throws NPE when loading h-tbl with more than 128 regions. Changed declaration to @transient private lazy val binarySearch = ...

sparksburnitt · sparksburnitt · commit dae6546373a1 · 2015-09-14T23:30:35.000Z
diff --git a/src/main/scala/org/apache/spark/sql/hbase/HBasePartitioner.scala b/src/main/scala/org/apache/spark/sql/hbase/HBasePartitioner.scala
@@ -41,7 +41,7 @@ class HBasePartitioner (var splitKeys: Array[HBaseRawType]) extends Partitioner
 
   def numPartitions = if (len == 0) 1 else len
 
-  @transient private val binarySearch: ((Array[t], t) => Int) = CollectionsUtils.makeBinarySearch[t]
+  @transient private lazy val binarySearch: ((Array[t], t) => Int) = CollectionsUtils.makeBinarySearch[t]
 
   def getPartition(key: Any): Int = {
     val k = key.asInstanceOf[t]
