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

How to understand 2 main() functions after using uftrace to profile the C++ program? -

i trying uftrace profile following simple c++ program: #include <iostream> class { public: a() {std::cout << "a created" << std::endl;} ~a() {std::cout << "a destroyed" << std::endl;} }; int main() { a; return 0; } the profile result this: # uftrace a.out created destroyed # duration tid function 2.026 [ 4828] | __cxa_atexit(); [ 4828] | main() { [ 4828] | __static_initialization_and_destruction_0() { 89.397 [ 4828] | std::ios_base::init::init(); 0.768 [ 4828] | __cxa_atexit(); 93.029 [ 4828] | } /* __static_initialization_and_destruction_0 */ 94.425 [ 4828] | } /* main */ [ 4828] | main() { [ 4828] | a::a() { 11.104 [ 4828] | std::operator <<(); 10.825 [ 4828] | std::basic_ostream::operator <<(); 24.514 [ 4828] | } /* a::a */ [ 4828] | a::~a() { 0.978 [ 4828] | ...
Read more

c# - Update a combobox from a presenter (MVP) -

i using mvp in project, new in mvp. have 2 comboboxes. when select option in combobox, combobox should filled new data. this action in presenter. view 'view1' in presenter, , introduced combobox1 , combobox2 properties in 'view1', because need 'datasource', 'displaymember', 'valuemember' , 'refresh()' in method below. but, when using pattern, enough send property like public string combobox2 { { return combobox1.selectedvalue.tosstring(); } } into presenter not whole combobox. how can solve problem? public void onselectedindexchangedcombobox1() { if (view1.combobox1.selectedindex == -1) { return; } datatable dt = tools.getdatatable("a path"); var query = (from o in dt.asenumerable() o.field<string>("afield") == farmerview.combobox1.selectedvalue.tostring() orderby o.field<string>("anotherfield") select...
Read more

How to put a lock and transaction on table using spring 4 or above using jdbcTemplate and annotations like @Transactional? -

i trying put lock on table while writing on table , if happened in between roll-back . trying convert below code lock table test_g1 read; lock table test_g write; -- begin; start transaction; insert test_g1 values(143); insert test_g values(145); select * test_g1; select * test_g; rollback; select * test_g; unlock tables; how convert above code @transactional spring jdbctemplate code? @transactional(rollbackfor={dataaccessexception.class}) public void test(){ jdbctemplate.execute("insert test1 (id, nam) values (4, 'a')"); throw new dataaccessexception("error") { }; } here trying throw error, insert statement should rollback it's not happening . thanks edit-1 attaching code , doing in jdbcdaoimpl.java , mentioned problem comment above test() . app.java package com.cgiri.javabrains.spring4; import org.springframework.beans.factory.annotation.autowired; import org.springframework.context.applic...
Read more