Carlos A. Morillo created HBASE-21304:
-----------------------------------------
Summary: HBaseBulkGetExample throws NullPointerException
Key: HBASE-21304
URL: https://issues.apache.org/jira/browse/HBASE-21304
Project: HBase
Issue Type: Bug
Components: spark
Reporter: Carlos A. Morillo
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)
