[ https://issues.apache.org/jira/browse/HBASE-21304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Artem Ervits reassigned HBASE-21304: ------------------------------------ Assignee: Artem Ervits > HBaseBulkGetExample throws NullPointerException > ----------------------------------------------- > > Key: HBASE-21304 > URL: https://issues.apache.org/jira/browse/HBASE-21304 > Project: HBase > Issue Type: Bug > Components: spark > Affects Versions: 3.0.0 > Reporter: Carlos A. Morillo > Assignee: Artem Ervits > Priority: Minor > Labels: beginner > > Running the HBaseContext Examples available at > [https://github.com/apache/hbase/tree/master/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/example/hbasecontext] > > If you run them in sequence, let's say you run first HBaseBulkPutExample > [https://github.com/apache/hbase/blob/master/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/example/rdd/HBaseBulkPutExample.scala] > and immediately after you run HBaseBulkGetExample > [https://github.com/apache/hbase/blob/master/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/example/rdd/HBaseBulkGetExample.scala] > You get a NullPointerException. > In the API > [https://github.com/apache/hbase/blob/master/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/example/hbasecontext/HBaseBulkGetExample.scala] > we have: > h4. defhbaseBulkGet(hc: > [HBaseContext|http://hbase.apache.org/hbase-spark/scaladocs/org/apache/hadoop/hbase/spark/HBaseContext.html], > tableName: TableName, batchSize: Int, f: (T) ⇒ Get): > RDD[(ImmutableBytesWritable, Result)] > Implicit method that gives easy access to HBaseContext's bulk get. This will > return a new RDD. Think about it as a RDD map function. In that every RDD > value will get a new value out of HBase. That new value will populate the > newly generated RDD. > hc > The hbaseContext object to identify which HBase cluster connection to use > tableName > The tableName that the put will be sent to > batchSize > How many gets to execute in a single batch > f > The function that will turn the RDD values in HBase Get objects > returns > A resulting RDD with type R objects > So it seems the function f passed to should be modified as an Scala partial > function to handle the case when the Result is null. > One possible fix would be {color:#000000}to call in an{color}{color:#000000} > if > {{[Result.isEmpty()|https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/client/Result.html#isEmpty--] > to make sure it isn't empty.}}{color} > {color:#000000}{{The API for Result.listCells expressly says it can return > null if there are no results.}}{color} -- This message was sent by Atlassian JIRA (v7.6.3#76005)