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 - Bypass Geo Redirect for specific directories -

i'm trying bypass redirect specific url within site. wondering if might able help. the code below code use, original urls replaces example.com i'd able access http://example.com/admin without redirect occuring. is there way this, , there way using own ip? function country_geo_redirect() { $country = getenv('http_geoip_country_code'); if ($country == "us" ) { wp_redirect("http://usa.example.com/"); exit; } else if ($country == "gb" ) { wp_redirect("http://uk.example.com/"); exit; } } add_action('init', 'country_geo_redirect'); you can bypass redirection code if server found ip address. if ip address == <my ip address> ' nothing here else country_georedirect() end if
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