You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Jonathan Yom-Tov <jo...@gmail.com> on 2015/02/10 18:15:01 UTC

Is it possible to run multiple LocalCluster instances?

hi,

I'm trying to run two LocalCluster instances, each one in a separate
thread. Is that generally possible? What would be the best way of doing it?
Right now I'm getting the following exception:


11719 [Thread-0] WARN org.apache.zookeeper.server.ZooKeeperServer - Failed
to register with JMX
javax.management.InstanceAlreadyExistsException:
org.apache.ZooKeeperService:name0=StandaloneServer_port-1
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at
com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.zookeeper.jmx.MBeanRegistry.register(MBeanRegistry.java:98)
at
org.apache.zookeeper.server.ZooKeeperServer.registerJMX(ZooKeeperServer.java:355)
at
org.apache.zookeeper.server.ZooKeeperServer.startup(ZooKeeperServer.java:388)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.startup(NIOServerCnxnFactory.java:123)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
at
backtype.storm.zookeeper$mk_inprocess_zookeeper.doInvoke(zookeeper.clj:182)
at clojure.lang.RestFn.invoke(RestFn.java:410)
at backtype.storm.testing$mk_local_storm_cluster.doInvoke(testing.clj:122)
at clojure.lang.RestFn.invoke(RestFn.java:421)
at backtype.storm.LocalCluster$_init.invoke(LocalCluster.clj:28)
at backtype.storm.LocalCluster.<init>(Unknown Source)