hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Cyril Scetbon <cyril.scet...@free.fr>
Subject Re: Coprocessor POC
Date Mon, 30 Jul 2012 13:10:10 GMT
Here is the stack : (with hbase-0.94.0.jar)

row count is 1
12/07/30 15:08:53 WARN client.HConnectionManager$HConnectionImplementation: Error executing
for row 
java.util.concurrent.ExecutionException: org.apache.hadoop.hbase.client.RetriesExhaustedException:
Failed after attempts=10, exceptions:
Mon Jul 30 15:08:14 CEST 2012, org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@341049d3, java.io.IOException:
java.io.IOException: java.lang.NullPointerException
	at org.apache.hadoop.hbase.coprocessor.AggregateImplementation.getAvg(AggregateImplementation.java:189)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.apache.hadoop.hbase.regionserver.HRegion.exec(HRegion.java:4770)
	at org.apache.hadoop.hbase.regionserver.HRegionServer.execCoprocessor(HRegionServer.java:3457)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.apache.hadoop.hbase.ipc.WritableRpcEngine$Server.call(WritableRpcEngine.java:364)
	at org.apache.hadoop.hbase.ipc.HBaseServer$Handler.run(HBaseServer.java:1376)

Regards
Cyril SCETBON

On Jul 29, 2012, at 11:54 PM, yuzhihong@gmail.com wrote:

> Can you use 0.94 for your client jar ?
> 
> Please show us the NullPointerException stack. 
> 
> Thanks
> 
> 
> 
> On Jul 29, 2012, at 2:49 PM, Cyril Scetbon <cyril.scetbon@free.fr> wrote:
> 
>> Hi,
>> 
>> I'm testing AggregationClient functions to check if we could use coprocessors for
mathematical functions.
>> 
>> The code I use is the following :
>> 
>> package coreprocessor;
>> 
>> import org.apache.hadoop.conf.Configuration;
>> import org.apache.hadoop.hbase.HBaseConfiguration;
>> import org.apache.hadoop.hbase.client.Scan;
>> import org.apache.hadoop.hbase.client.coprocessor.AggregationClient;
>> import org.apache.hadoop.hbase.util.Bytes;
>> 
>> public class AggregationClientTest {
>> 
>>  private static final byte[] TABLE_NAME = Bytes.toBytes("ise");
>>  private static final byte[] CF = Bytes.toBytes("core");
>> 
>>  public static void main(String[] args) throws Throwable {
>> 
>>      Configuration configuration = HBaseConfiguration.create();
>> 
>>      configuration.setLong("hbase.client.scanner.caching", 1000);
>>      AggregationClient aggregationClient = new AggregationClient(
>>              configuration);
>>      Scan scan = new Scan();
>>      scan.addColumn(CF, Bytes.toBytes("value"));
>>      System.out.println("row count is " + aggregationClient.rowCount(TABLE_NAME,
null, scan));
>>      System.out.println("avg is " + aggregationClient.avg(TABLE_NAME, null, scan));
>>      System.out.println("sum is " + aggregationClient.sum(TABLE_NAME, null, scan));
>>  }
>> }
>> 
>> The only one working is the rowCount function. For others I get a NPE error !
>> I've checked that my table use only Long values for the column on which I work, and
I've only one row in my table :
>> 
>> ROW                                                  COLUMN+CELL                
                                                                                         
                                 
>> id-cyr1                                             column=core:value, timestamp=1343596419845,
value=\x00\x00\x00\x00\x00\x00\x00\x0A                                                   
                 
>> 
>> The only thing I can add is that my hbase server's version is 0.94.0 and that I use
version 0.92.0 of the hbase jar
>> 
>> any idea why it doesn't work ?
>> 
>> thanks 
>> Cyril SCETBON
>> 


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message