Also, the same code works perfectly fine when i run it in single node
cluster. I've added the hbase classpath to HADOOP_CLASSPATH and have set
all the other env variables also..


On Mon, Aug 19, 2013 at 6:33 PM, Pavan Sudheendra <[email protected]>wrote:

> Hi all,
> I'm getting the following error messages everytime i run the map-reduce
> job across multiple hadoop clusters:
>
> java.lang.NullPointerException
>     at org.apache.hadoop.hbase.util.Bytes.toBytes(Bytes.java:414)
>     at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:170)
> at com.company$AnalyzeMapper.contentidxjoin(MRjobt.java:153)
>
>
> Here's the code:
>
> public void map(ImmutableBytesWritable row, Result columns, Context
> context)
>     throws IOException {
> ...
> ...
> public static String contentidxjoin(String contentId) {
> Configuration conf = HBaseConfiguration.create();
>           HTable table;
>         try {
>             table = new HTable(conf, ContentidxTable);
>             if(table!= null) {
>             Get get1 = new Get(Bytes.toBytes(contentId));
>             get1.addColumn(Bytes.toBytes(ContentidxTable_ColumnFamily),
> Bytes.toBytes(ContentidxTable_ColumnQualifier));
>             Result result1 = table.get(get1);
>             byte[] val1 =
> result1.getValue(Bytes.toBytes(ContentidxTable_ColumnFamily),
>                   Bytes.toBytes(ContentidxTable_ColumnQualifier));
>             if(val1!=null) {
>                 LOGGER.info("Fetched data from BARB-Content table");
>             } else {
>                 LOGGER.error("Error fetching data from BARB-Content
> table");
>             }
>             return_value = contentjoin(Bytes.toString(val1),contentId);
>             }
>         }
> catch (Exception e) {
>             LOGGER.error("Error inside contentidxjoin method");
>             e.printStackTrace();
>         }
>         return return_value;
> }
> }
>
> Assume all variables are defined.
>
> Can anyone please tell me why the table never gets instantiated or
> entered? I had set up break points and this function gets called many times
> while mapper executes.. everytime it says *Error inside contentidxjoin
> method*.. I'm 100% sure there are rows in the ContentidxTable so not sure
> why its not able to fetch the value from it..
>
> Please help!
>
>
> --
> Regards-
> Pavan
>



-- 
Regards-
Pavan

Reply via email to