Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 50EB11086A for ; Tue, 10 Feb 2015 17:16:24 +0000 (UTC) Received: (qmail 28587 invoked by uid 500); 10 Feb 2015 17:16:13 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 28543 invoked by uid 500); 10 Feb 2015 17:16:13 -0000 Mailing-List: contact user-help@storm.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.apache.org Delivered-To: mailing list user@storm.apache.org Received: (qmail 28533 invoked by uid 99); 10 Feb 2015 17:16:13 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Feb 2015 17:16:13 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of jon.yomtov@gmail.com designates 209.85.217.175 as permitted sender) Received: from [209.85.217.175] (HELO mail-lb0-f175.google.com) (209.85.217.175) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Feb 2015 17:16:07 +0000 Received: by mail-lb0-f175.google.com with SMTP id n10so33116658lbv.6 for ; Tue, 10 Feb 2015 09:15:01 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=dkLVW0MRoiRv7Sl14D9GMhJX88sZBB1umzO+Udt/gFU=; b=HKamiSvwqM9fNSQkwLWJmrWutluaZIyXtWb3rqgGkhEiiGUpV0znlrKIyVwqsKxCQH 1Y9hQhy1xCVfJAYxxtd9Ep9Yt9OqLiirgygimHRsoo7qyG9UpZE/h40y5jrtN7YHlkqb DqOnZE3A7kfLV96pXd82SH/7O5ZrToOq+SO9ZOGhoqR7gpxNsUV8fFvQYMHZqYYQiSNy 3UVLIZ3/F3iIPFXgMdnvX6QlToenr1L3gvswxJDZJam2+xrbgzdBI5nANlgC0ZVE8YEW 2RwTRNJ4R0ol+VXEKIxCqEQmOQwMgdF36DCXGuhD2l8eTlsLRxJXLWa1cfW6o9lfSvqG Fgpw== MIME-Version: 1.0 X-Received: by 10.112.130.34 with SMTP id ob2mr24426295lbb.78.1423588501807; Tue, 10 Feb 2015 09:15:01 -0800 (PST) Received: by 10.114.64.144 with HTTP; Tue, 10 Feb 2015 09:15:01 -0800 (PST) Date: Tue, 10 Feb 2015 19:15:01 +0200 Message-ID: Subject: Is it possible to run multiple LocalCluster instances? From: Jonathan Yom-Tov To: user@storm.apache.org Content-Type: multipart/alternative; boundary=047d7b3a7f0af4eb65050ebf06fd X-Virus-Checked: Checked by ClamAV on apache.org --047d7b3a7f0af4eb65050ebf06fd Content-Type: text/plain; charset=UTF-8 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.(Unknown Source) --047d7b3a7f0af4eb65050ebf06fd Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
hi,

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


11719 [Thread-0] WARN org.apache.zo= okeeper.server.ZooKeeperServer - Failed to register with JMX
java= x.management.InstanceAlreadyExistsException: org.apache.ZooKeeperService:na= me0=3DStandaloneServer_port-1
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.j= ava:437)
at co= m.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(= DefaultMBeanServerInterceptor.java:1898)
at com.sun.jmx.interceptor.DefaultMBeanServerI= nterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at com.sun.jmx.in= terceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerIn= terceptor.java:900)
<= /span>at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBea= n(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.regi= sterMBean(JmxMBeanServer.java:522)
at org.apache.zookeeper.jmx.MBeanRegistry.register(MBe= anRegistry.java:98)
<= /span>at org.apache.zookeeper.server.ZooKeeperServer.registerJMX(ZooKeeperS= erver.java:355)
at org.apache.zookeeper.server.ZooKeeperServer.startup(ZooKeeperServer.ja= va:388)
at org= .apache.zookeeper.server.NIOServerCnxnFactory.startup(NIOServerCnxnFactory.= java:123)
at s= un.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAcc= essorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccesso= rImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Met= hod.java:606)
= at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflect= or.invokeInstanceMethod(Reflector.java:28)
at backtype.storm.zookeeper$mk_inprocess_zooke= eper.doInvoke(zookeeper.clj:182)
at clojure.lang.RestFn.invoke(RestFn.java:410)
at backtype.storm.testi= ng$mk_local_storm_cluster.doInvoke(testing.clj:122)
at clojure.lang.RestFn.invoke(RestF= n.java:421)
at= backtype.storm.LocalCluster$_init.invoke(LocalCluster.clj:28)
at backtype.storm.LocalClu= ster.<init>(Unknown Source)
--047d7b3a7f0af4eb65050ebf06fd--