Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
HBase >> mail # user >> BigDecimalColumnInterpreter


Copy link to this message
-
Re: BigDecimalColumnInterpreter
I am using HBase0.92.1. Which version you are using?
On Thu, Sep 6, 2012 at 10:19 AM, anil gupta <[EMAIL PROTECTED]> wrote:

> Hi Julian,
>
> You need to add the column qualifier explicitly in the scanner. You have
> only added the column family in the scanner.
> I am also assuming that you are writing a ByteArray of BigDecimal object
> as value of these cells in HBase. Is that right?
>
> Thanks,
> Anil
>
>
> On Thu, Sep 6, 2012 at 2:28 AM, Julian Wissmann <[EMAIL PROTECTED]>wrote:
>
>> Hi, anil,
>>
>> I presume you mean something like this:
>>         Scan scan = new Scan(_start, _end);
>>         scan.addFamily(family.getBytes());
>>         final ColumnInterpreter<BigDecimal, BigDecimal> ci = new
>> mypackage.BigDecimalColumnInterpreter();
>>         AggregationClient ag = new org.apache.hadoop.hbase.
>> client.coprocessor.AggregationClient(config);
>>         BigDecimal sum = ag.sum(Bytes.toBytes(tableName), new
>> BigDecimalColumnInterpreter(), scan);
>>
>>
>> When I call this,with the Endpoint in place and loaded as a jar, I get the
>> above error.
>> When I call it without the endpoint loaded as coprocessor, though, I get
>> this:
>>
>> java.util.concurrent.ExecutionException:
>> org.apache.hadoop.hbase.client.RetriesExhaustedException: Failed after
>> attempts=10, exceptions:
>> Thu Sep 06 11:07:39 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:40 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:41 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:42 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:44 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:46 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:50 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:07:54 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:08:02 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>> Thu Sep 06 11:08:18 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields
>>
>> at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:252)
>> at java.util.concurrent.FutureTask.get(FutureTask.java:111)
>> at
>>
>> org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processExecs(HConnectionManager.java:1434)
>> at org.apache.hadoop.hbase.client.HTable.coprocessorExec(HTable.java:1263)
>> at
>>
>> org.apache.hadoop.hbase.client.coprocessor.AggregationClient.sum(AggregationClient.java:259)
>> at
>>
>> helpers.HbaseReaderBigDecimal.getWeeksumSCAN(HbaseReaderBigDecimal.java:355)
>> at helpers.HbaseReaderBigDecimal.main(HbaseReaderBigDecimal.java:76)
>> Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedException:
>> Failed
>> after attempts=10, exceptions:
>> Thu Sep 06 11:07:39 CEST 2012,
>> org.apache.hadoop.hbase.ipc.ExecRPCInvoker$1@7bd6747b,
>> java.io.IOException:
>> IPC server unable to read call parameters: Error in readFields

Thanks & Regards,
Anil Gupta
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB