Storm - Kafka strange exception -


on submitting storm topology, getting strange error exception. running on 1 vm throwing exception on another. not understand why happening, pasting whole stack trace:

java.lang.runtimeexception: java.lang.runtimeexception: org.apache.zookeeper.keeperexception$connectionlossexception: keepererrorcode = connectionloss /brokers/topics/visit/partitions  @ storm.kafka.dynamicbrokersreader.getbrokerinfo(dynamicbrokersreader.java:64)  @ storm.kafka.trident.zkbrokerreader.<init>(zkbrokerreader.java:25) @ storm.kafka.kafkautils.makebrokerreader(kafkautils.java:40) @ storm.kafka.kafkaspout.open(kafkaspout.java:70)  @ backtype.storm.daemon.executor$fn__4654$fn__4669.invoke(executor.clj:522)  @ backtype.storm.util$async_loop$fn__458.invoke(util.clj:461)  @ clojure.lang.afn.run(afn.java:24)  @ java.lang.thread.run(thread.java:745)  caused by: java.lang.runtimeexception:     org.apache.zookeeper.keeperexception$connectionlossexception: keepererrorcode = connectionloss /brokers/topics/visit/partitions @ storm.kafka.dynamicbrokersreader.getnumpartitions(dynamicbrokersreader.java:77) @ storm.kafka.dynamicbrokersreader.getbrokerinfo(dynamicbrokersreader.java:48) ... 7 more caused by: org.apache.zookeeper.keeperexception$connectionlossexception: keepererrorcode = connectionloss /brokers/topics/visit/partitions @ org.apache.zookeeper.keeperexception.create(keeperexception.java:99) @ org.apache.zookeeper.keeperexception.create(keeperexception.java:51) @ org.apache.zookeeper.zookeeper.getchildren(zookeeper.java:1590)   @ org.apache.curator.framework.imps.getchildrenbuilderimpl$3.call(getchildrenbuilderimpl.java:214)  @ org.apache.curator.framework.imps.getchildrenbuilderimpl$3.call(getchildrenbuilderimpl.java:203)  @ org.apache.curator.retryloop.callwithretry(retryloop.java:107)  @ org.apache.curator.framework.imps.getchildrenbuilderimpl.pathinforeground(getchildrenbuilderimpl.java:199)  @ org.apache.curator.framework.imps.getchildrenbuilderimpl.forpath(getchildrenbuilderimpl.java:191) @ org.apache.curator.framework.imps.getchildrenbuilderimpl.forpath(getchildrenbuilderimpl.java:38) @ storm.kafka.dynamicbrokersreader.getnumpartitions(dynamicbrokersreader.java:74) ... 8 more

the logs zookeeper :

3:16:19.497 pm  info    org.apache.zookeeper.server.nioservercnxnfactory     accepted socket connection /10.67.33.201:37346 3:16:19.498 pm  info    org.apache.zookeeper.server.zookeeperserver  client attempting establish new session @ /10.67.33.201:37346 3:16:19.501 pm  info    org.apache.zookeeper.server.zookeeperserver  established session 0x44db46775060e2e negotiated timeout 30000   client /10.67.33.201:37346 3:16:19.523 pm  info    org.apache.zookeeper.server.nioservercnxnfactory     accepted socket connection /10.67.33.201:37350 3:16:19.524 pm  info    org.apache.zookeeper.server.zookeeperserver  client attempting establish new session @ /10.67.33.201:37350 3:16:19.525 pm  info    org.apache.zookeeper.server.zookeeperserver  established session 0x44db46775060e2f negotiated timeout 30000   client /10.67.33.201:37350 3:16:19.591 pm  info    org.apache.zookeeper.server.preprequestprocessor     processed session termination sessionid: 0x54db467a6bd0d0c 3:16:19.595 pm  info    org.apache.zookeeper.server.preprequestprocessor     processed session termination sessionid: 0x14db46774a60d57 3:16:19.598 pm  info    org.apache.zookeeper.server.preprequestprocessor     processed session termination sessionid: 0x44db46775060e2f

since running on 1 cluster , not on other, guessing must cluster issue. great if 1 can point out problem.


Comments

Post a Comment

Popular posts from this blog

Magento/PHP - Get phones on all members in a customer group -

i working on custom magento extension. working around adminhtml part , i've created custom form there. here form code: <?php class vivasindustries_smsnotification_block_adminhtml_sms_sendmass_edit_form extends mage_adminhtml_block_widget_form { public function _preparelayout() { $extensionpath = mage::getmoduledir('js', 'vivasindustries_smsnotification'); $head = $this->getlayout()->getblock('head'); $head->addjs('jquery.js'); $head->addjs('vivas.js'); return parent::_preparelayout(); } protected function _prepareform() { $form = new varien_data_form(array( 'id' => 'edit_form', 'action' => $this->geturl('*/*/save', array('id' => $this->getrequest()->get
Read more

php - .htaccess mod_rewrite for dynamic url which has domain names -

i want convert url ex:( example.com/link.php?url=facebook.com ) ( example.com/facebook.com.php ) how can using .htaccess. or there other process make job easier ? i tried adding script .htaccess file options +followsymlinks rewriteengine on rewriterule url-(.*)\.htm$ link.php?url=$1 but converting url adding "url-" ( example.com/url-facebook.com.php ) i want remove "url-" , want make ( example.com/facebook.com.php ) rewriteengine on rewritecond %{the_request} ^get.*link\.php\?url\= [nc] rewritecond %{request_uri} !/system/.* [nc] rewriterule (.*?)link\.php\?url\=/*(.*) /$1$2 [r=301,ne,l] not sure how above work edit of used use remove index.php url
Read more

Website Login Issue developed in magento -

i have website developed using magento . able login. right now, login failed. infact operations interacts user table failing. need know issue. how figure out? first clear try clear log file second make sure have not upgraded magento and 3rd make sure db accessible in magento -harry p
Read more