Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0633E18BCB for ; Tue, 9 Feb 2016 13:51:32 +0000 (UTC) Received: (qmail 47578 invoked by uid 500); 9 Feb 2016 13:51:31 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 47536 invoked by uid 500); 9 Feb 2016 13:51:31 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 47526 invoked by uid 99); 9 Feb 2016 13:51:30 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Feb 2016 13:51:30 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 84FAE1A01F6 for ; Tue, 9 Feb 2016 13:51:30 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.534 X-Spam-Level: X-Spam-Status: No, score=-0.534 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, RCVD_IN_DNSWL_MED=-2.3, RP_MATCHES_RCVD=-0.233, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id y0aZmFTM5Af9 for ; Tue, 9 Feb 2016 13:51:28 +0000 (UTC) Received: from smtpout01-ttc.target.com (smtpout03.target.com [161.225.129.10]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 6883331ADE for ; Tue, 9 Feb 2016 13:51:27 +0000 (UTC) Received: from tcttsdlp1p.hq.target.com (HELO TEEMAIL01P.hq.target.com) ([10.65.182.57]) by smtpout01-ttc.target.com with ESMTP; 09 Feb 2016 07:51:07 -0600 Received: from teemlmbx12p.hq.target.com (10.66.134.25) by TEEMAIL01P.hq.target.com (10.66.18.22) with Microsoft SMTP Server (TLS) id 14.3.195.1; Tue, 9 Feb 2016 07:51:07 -0600 Received: from teemlmbx12p.hq.target.com (10.66.134.25) by teemlmbx12p.hq.target.com (10.66.134.25) with Microsoft SMTP Server (TLS) id 15.0.1104.5; Tue, 9 Feb 2016 07:51:07 -0600 Received: from teemlmbx12p.hq.target.com ([fe80::6dd1:1494:700c:4f4c]) by teemlmbx12p.hq.target.com ([fe80::6dd1:1494:700c:4f4c%16]) with mapi id 15.00.1104.000; Tue, 9 Feb 2016 07:51:07 -0600 From: Raja.Aravapalli To: "user@storm.apache.org" Subject: HBase lookup bolt - exception Thread-Topic: HBase lookup bolt - exception Thread-Index: AQHRY0DsS6CfdWKGG0KlBS+AAuqT3w== Date: Tue, 9 Feb 2016 13:51:06 +0000 Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-ms-exchange-messagesentrepresentingtype: 1 x-ms-exchange-transport-fromentityheader: Hosted x-originating-ip: [10.113.1.89] Content-Type: multipart/alternative; boundary="_000_D2DFEC8BA012RajaAravapallitargetcom_" MIME-Version: 1.0 X-CFilter-Loop: Reflected --_000_D2DFEC8BA012RajaAravapallitargetcom_ Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable Hi, For the HBase lookup bolt of my storm topology, i am facing below exception= ... Request your help to identify and fix the issue ASAP. java.lang.RuntimeException: java.lang.IllegalArgumentException: Row length = is 0 at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQ= ueue.java:128) at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvail= able(DisruptorQueue.java:99) at backtype.storm.disruptor$consume_batch_when= _available.invoke(disruptor.clj:80) at backtype.storm.daemon.executor$fn__5= 265$fn__5278$fn__5329.invoke(executor.clj:794) at backtype.storm.util$async= _loop$fn__551.invoke(util.clj:465) at clojure.lang.AFn.run(AFn.java:24) at = java.lang.Thread.run(Thread.java:744) Caused by: java.lang.IllegalArgumentE= xception: Row length is 0 at org.apache.hadoop.hbase.client.Mutation.checkR= ow(Mutation.java:503) at org.apache.hadoop.hbase.client.Mutation.checkRow(M= utation.java:487) at org.apache.hadoop.hbase.client.Get.(Get.java:89)= at org.apache.storm.hbase.common.HBaseClient.constructGetRequests(HBaseCli= ent.java:112) at org.apache.storm.hbase.bolt.HBaseLookupBolt.execute(HBaseL= ookupBolt.java:65) at backtype.storm.daemon.executor$fn__5265$tuple_action_= fn__5267.invoke(executor.clj:659) at backtype.storm.daemon.executor$mk_task= _receiver$fn__5188.invoke(executor.clj:415) at backtype.storm.disruptor$clo= jure_handler$reify__1064.onEvent(disruptor.clj:58) at backtype.storm.utils.= DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125) ... 6 more Code used: public class LookUpHBaseBolt { public static HBaseLookupBolt getHBaseLookupBolt(String rkey, String co= lfam, String tablename) { SimpleHBaseMapper lookupMapper =3D new SimpleHBaseMapper().withRowK= eyField(rkey); HBaseProjectionCriteria projectCriteria =3D new HBaseProjectionCrit= eria(); projectCriteria.addColumnFamily(colfam); HBaseRowValueMapper row2TupleMapper =3D new HBaseRowValueMapper(); HBaseLookupBolt hbaseLkpBolt =3D new HBaseLookupBolt(tablename, loo= kupMapper, row2TupleMapper) .withProjectionCriteria(projectCriteria); return hbaseLkpBolt; } } Please share your thoughts and help me fix the issue. Thanks. Regards, Raja. --_000_D2DFEC8BA012RajaAravapallitargetcom_ Content-Type: text/html; charset="iso-8859-1" Content-ID: <006B32C627868242A9D0D94C0A0A9433@target.com> Content-Transfer-Encoding: quoted-printable

Hi,

For the HBase lookup bolt of my storm topology, i am facing below exce= ption… Request your help to identify and fix the issue ASAP.  

java.lang.RuntimeException: jav= a.lang.IllegalArgumentException: Row length is 0 at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(Di= sruptorQueue.java:128) at backtype.storm.utils.DisruptorQueue.consumeBatchW= henAvailable(DisruptorQueue.java:99) at backtype.storm.disruptor$consume_ba= tch_when_available.invoke(disruptor.clj:80) at backtype.storm.daemon.executor$fn__5265$fn__5278$fn__5329.invoke(execut= or.clj:794) at backtype.storm.util$async_loop$fn__551.invoke(util.clj:465) = at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:74= 4) Caused by: java.lang.IllegalArgumentException: Row length is 0 at org.apache.hadoop.hbase.client.Mutation.checkRow(Mutati= on.java:503) at org.apache.hadoop.hbase.client.Mutation.checkRow(Mutation.j= ava:487) at org.apache.hadoop.hbase.client.Get.<init>(Get.java:89) at= org.apache.storm.hbase.common.HBaseClient.constructGetRequests(HBaseClient= .java:112) at org.apache.storm.hbase.bolt.HBaseLookupBolt.execute(HBaseLookupBolt.jav= a:65) at backtype.storm.daemon.executor$fn__5265$tuple_action_fn__5267.invo= ke(executor.clj:659) at backtype.storm.daemon.executor$mk_task_receiver$fn_= _5188.invoke(executor.clj:415) at backtype.storm.disruptor$clojure_handler$reify__1064.onEvent(disruptor.clj= :58) at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQ= ueue.java:125) ... 6 more


 Code used:
public class=
 LookUpHBaseBolt {

    public static HBaseLookupBolt getHBaseLookupBolt(String rk=
ey, String colfam, String tablename) {

        SimpleHBaseMapper loo=
kupMapper =3D new Si=
mpleHBaseMapper().withRowKeyField(rkey);

        HBaseProjectionCrit=
eria projectCriteria =3D ne=
w HBaseProjectionCriteria();
        projectCriteria.addColumnFam=
ily(colfam);

        HBaseRowValueMapper row2TupleMapper =3D new HBaseRowValueMapper();<=
br>
        HBaseLookupBolt hbaseLkpBolt =3D new HBaseLookupBolt(tablename, lookupMapper, ro=
w2TupleMapper)
                .withProjectionCriteria(projectCriteria);=


        return hbaseLkpBolt;
    }

}

Please share your thoughts and help me fix the issue. Thanks.


Regards,
Raja.
--_000_D2DFEC8BA012RajaAravapallitargetcom_--