hadoop - Testing java HBase connection -


i trying use hbase java apis write data hbase. installed hadoop/hbase through ambari.

here how configuration set up:

final configuration configuration = hbaseconfiguration.create(); final hbaseadmin hbase_admin;  hbase_admin = new hbaseadmin(configuration)

when try write hbase, check make sure table exists 

!hbase_admin.tableexists(tablename)

if not, create new one. however, appears when attempting check if table exists exceptions being thrown.

i'm wondering if i'm not correctly connected hbase...is there way verify configuration correct , connecting hbase? exception i'm getting below.

thanks.

java.lang.runtimeexception: java.lang.nullpointerexception   @ org.apache.hadoop.hbase.client.rpcretryingcaller.callwithoutretries(rpcretryingcaller.java:209)   @ org.apache.hadoop.hbase.client.clientscanner.call(clientscanner.java:288)   @ org.apache.hadoop.hbase.client.clientscanner.nextscanner(clientscanner.java:268)   @ org.apache.hadoop.hbase.client.clientscanner.initializescannerinconstruction(clientscanner.java:140)   @ org.apache.hadoop.hbase.client.clientscanner.<init>(clientscanner.java:135)   @ org.apache.hadoop.hbase.catalog.metareader.fullscan(metareader.java:597)   @ org.apache.hadoop.hbase.client.htable.getscanner(htable.java:802)   @ org.apache.hadoop.hbase.catalog.metareader.tableexists(metareader.java:359)   @ org.apache.hadoop.hbase.client.hbaseadmin.tableexists(hbaseadmin.java:287)   @ org.apache.hadoop.hbase.client.hbaseadmin.tableexists(hbaseadmin.java:301)   @ com.business.project.hbase.hbasemessagewriter.gettable(hbasemessagewriter.java:40)   @ com.business.project.hbase.hbasemessagewriter.write(hbasemessagewriter.java:59)   @ com.business.project.hbase.hbasemessagewriter.write(hbasemessagewriter.java:54)   @ com.business.project.storm.bolt.package.examplebolt.execute(examplebolt.java:19)   @ backtype.storm.daemon.executor$fn__5697$tuple_action_fn__5699.invoke(executor.clj:659)   @ backtype.storm.daemon.executor$mk_task_receiver$fn__5620.invoke(executor.clj:415)   @ backtype.storm.disruptor$clojure_handler$reify__1741.onevent(disruptor.clj:58)   @ backtype.storm.utils.disruptorqueue.consumebatchtocursor(disruptorqueue.java:125)   @ backtype.storm.utils.disruptorqueue.consumebatchwhenavailable(disruptorqueue.java:99)   @ backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80)   @ backtype.storm.daemon.executor$fn__5697$fn__5710$fn__5761.invoke(executor.clj:794)   @ backtype.storm.util$async_loop$fn__452.invoke(util.clj:465)   @ clojure.lang.afn.run(afn.java:24)   @ java.lang.thread.run(thread.java:745) caused by: java.lang.nullpointerexception   @ org.apache.hadoop.hbase.zookeeper.zookeeperwatcher.getmetareplicanodes(zookeeperwatcher.java:269)   @ org.apache.hadoop.hbase.zookeeper.metaregiontracker.blockuntilavailable(metaregiontracker.java:241)   @ org.apache.hadoop.hbase.client.zookeeperregistry.getmetaregionlocation(zookeeperregistry.java:62)   @ org.apache.hadoop.hbase.client.connectionmanager$hconnectionimplementation.locatemeta(connectionmanager.java:1203)   @ org.apache.hadoop.hbase.client.connectionmanager$hconnectionimplementation.locateregion(connectionmanager.java:1164)   @ org.apache.hadoop.hbase.client.rpcretryingcallerwithreadreplicas.getregionlocations(rpcretryingcallerwithreadreplicas.java:294)   @ org.apache.hadoop.hbase.client.scannercallablewithreplicas.call(scannercallablewithreplicas.java:130)   @ org.apache.hadoop.hbase.client.scannercallablewithreplicas.call(scannercallablewithreplicas.java:55)   @ org.apache.hadoop.hbase.client.rpcretryingcaller.callwithoutretries(rpcretryingcaller.java:201)

in addition configuration parameters suggested yosr, specifying 

conf.set("zookeeper.znode.parent", "value")

would resolve issue.


Comments

Post a Comment

Popular posts from this blog

Retrieving ETA (estimated time of arrival) with Google Distance Matrix API and public transit as transport mode -

Image
is possible retrieve eta google's distancematrix api (or alternative api). fyi, eta different duration, when using public transport. following example clarify request. when leave on friday @ 8.15 i'll able catch train @ 8.30 , arrive @ 9.00 am. google says duration 30 minutes. however, when leave on saturday @ 8.15 i'll able catch first train @ 9.00 , arrive @ 9.30 am. google still says duration 30 minutes, means ignore delay. google map supports functionality there api around giving me eta instead of duration. can see, distance-matrix' response no good. clarifying question little. eta estimated time of arrival , it's clear user wants know entire duration of transport (including waiting time public transport).
Read more

javascript - Confirm a form & display message if form is valid with JQuery -

i'm developing django application , use javascript in order improve website. i have form , display 2 things : confirm form before submit if form submitted, display message : 'form saved' it's first time i'm using js , need make process. this code : <form class = "form" method='post' action=''> {% csrf_token %} <br></br> {{ form.as_p}} <br></br> <button type="submit">valider</button> </form> <script> $('#form').submit(function() { var c = confirm("click ok continue?"); return c; //you can return c because true or false }); </script> and if form valid , saved : <script type="text/javascript" > $(document).on('valider', 'form.form', function(form) { var $form = $(form); $.ajax({ ...
Read more

ionic framework - Meteor - Error: Failed to execute 'insertBefore' on 'Node' -

i trying make dynamic list display using meteor, idea load more elements each time bottom of page reached. the html template following : <template name="contacts"> {{#contentfor "headertitle"}} <div class="bar bar-header bar-assertive"> <h1 class="title">contacts :</h1> </div> {{/contentfor}} {{#ionview}} {{#ioncontent}} <div class="list"> {{#each contacts}} <a class="item item-avatar" href="/contacts/{{_id}}"> <img src="/img/ico_client.png"> <h2>{{full_name}}</h2> <p>{{company}}</p> </a> {{/each}} </div> {{#if moreresults}} <div id="showmoreresults" style="margin-left: 25px;"> <span class="loading">loading...</span> </div> {{/if}} {{/ioncontent}} {{/ionview}} </te...
Read more