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 9D2D110155 for ; Wed, 30 Apr 2014 05:10:23 +0000 (UTC) Received: (qmail 75156 invoked by uid 500); 30 Apr 2014 05:10:22 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 75127 invoked by uid 500); 30 Apr 2014 05:10:22 -0000 Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.incubator.apache.org Delivered-To: mailing list user@storm.incubator.apache.org Received: (qmail 75118 invoked by uid 99); 30 Apr 2014 05:10:22 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Apr 2014 05:10:22 +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 (nike.apache.org: domain of lasantha.fdo@gmail.com designates 209.85.216.47 as permitted sender) Received: from [209.85.216.47] (HELO mail-qa0-f47.google.com) (209.85.216.47) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 30 Apr 2014 05:10:18 +0000 Received: by mail-qa0-f47.google.com with SMTP id j7so1185807qaq.34 for ; Tue, 29 Apr 2014 22:09:55 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=wD+iXPRSIl0jvq8YMJMpk8xxEs7fnG3Cy078OEPkNlM=; b=s9sL+2LdnJoFdadFiPjzfbrw2EfesLm5KmffEAlV807QwEZVJeTlaBHjyluLCdGlEm MgVqd+0MpGBUZNvt21ttTj+ccrHahRw1IBY0uYrTE5nfDtjkudFg5HmqxhYqxw6HmDA2 sKGtg78EK4XxgEiZOn0GOo0qyaWPifj8ZUtwdQrOVkqR8n5J40s/B+1hAMoxMdVWFZt8 CFtn7iHGZXHVMiKd3pCqspt+BKSR7fqRVbnP1yXDmRwYKAtrb1HGD4hBM7D2O9jCKYr7 /h+Uu+7yVPb1MXVpww2JOOg7S5+cyLZ1d6wertjAMR7rsnB1sMnkooAnfEnLhEl1Kw61 RDRg== MIME-Version: 1.0 X-Received: by 10.224.50.81 with SMTP id y17mr2306342qaf.22.1398834595224; Tue, 29 Apr 2014 22:09:55 -0700 (PDT) Received: by 10.140.81.208 with HTTP; Tue, 29 Apr 2014 22:09:55 -0700 (PDT) In-Reply-To: References: Date: Wed, 30 Apr 2014 10:39:55 +0530 Message-ID: Subject: Re: Replace Netty with ZeroMQ in Storm 0.9.1 From: Lasantha Fernando To: user@storm.incubator.apache.org Content-Type: multipart/alternative; boundary=047d7bf0c12225e29d04f83b8fc4 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bf0c12225e29d04f83b8fc4 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi all, Stumbled upon this thread when trying to switch to zeromq and came across this error after putting the storm-0mq to /lib directory. java.lang.ExceptionInInitializerError: null at java.lang.Class.forName0(Native Method) ~[na:1.6.0_45] at java.lang.Class.forName(Class.java:249) ~[na:1.6.0_45] at clojure.lang.RT.loadClassForName(RT.java:2056) ~[clojure-1.4.0.jar:na] at clojure.lang.RT.load(RT.java:419) ~[clojure-1.4.0.jar:na] at clojure.lang.RT.load(RT.java:400) ~[clojure-1.4.0.jar:na] at clojure.core$load$fn__4890.invoke(core.clj:5415) ~[clojure-1.4.0.jar:na] at clojure.core$load.doInvoke(core.clj:5414) ~[clojure-1.4.0.jar:na] at clojure.lang.RestFn.invoke(RestFn.java:408) [clojure-1.4.0.jar:na] at clojure.lang.Var.invoke(Var.java:415) ~[clojure-1.4.0.jar:na] at backtype.storm.messaging.zmq.(Unknown Source) ~[storm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT] at java.lang.Class.forName0(Native Method) ~[na:1.6.0_45] at java.lang.Class.forName(Class.java:171) ~[na:1.6.0_45] at backtype.storm.messaging.TransportFactory.makeContext(TransportFactory.java= :38) ~[storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSHOT] at backtype.storm.daemon.worker$worker_data$fn__4263.invoke(worker.clj:185) ~[na:0.9.2-incubating-SNAPSHOT] at backtype.storm.util$assoc_apply_self.invoke(util.clj:792) ~[storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSHOT] at backtype.storm.daemon.worker$worker_data.invoke(worker.clj:181) ~[storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSHOT] at backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414.invoke(wo= rker.clj:353) ~[na:0.9.2-incubating-SNAPSHOT] at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.4.0.jar:na] at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.4.0.jar:na] at clojure.core$apply.invoke(core.clj:601) ~[clojure-1.4.0.jar:na] at backtype.storm.daemon.worker$eval4413$mk_worker__4469.doInvoke(worker.clj:3= 44) [na:0.9.2-incubating-SNAPSHOT] at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.4.0.jar:na] at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) [na:0.9.2-incubating-SNAPSHOT] at clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.4.0.jar:na] at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.4.0.jar:na] at backtype.storm.daemon.worker.main(Unknown Source) [storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSHOT] Caused by: java.lang.ClassNotFoundException: org.zeromq.ZMQ at java.net.URLClassLoader$1.run(URLClassLoader.java:202) ~[na:1.6.0_45] at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_45= ] at java.net.URLClassLoader.findClass(URLClassLoader.java:190) ~[na:1.6.0_45= ] at java.lang.ClassLoader.loadClass(ClassLoader.java:306) ~[na:1.6.0_45] at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) ~[na:1.6.0_45] at java.lang.ClassLoader.loadClass(ClassLoader.java:247) ~[na:1.6.0_45] at java.lang.Class.forName0(Native Method) ~[na:1.6.0_45] at java.lang.Class.forName(Class.java:171) ~[na:1.6.0_45] at backtype.storm.messaging.zmq$loading__4784__auto__.invoke(zmq.clj:1) ~[storm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT] at backtype.storm.messaging.zmq__init.load(Unknown Source) ~[storm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT] at backtype.storm.messaging.zmq__init.(Unknown Source) ~[storm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT] ... 26 common frames omitted This got resolved after copying 'zmq.jar' from /usr/local/share/java/ to the lib directory as well. There might be other ways to resolve this issue other than copying the 'zmq.jar'. Just shared in case it will be useful for someone who comes across a similar issue. Thanks, Lasantha On Mon, Apr 7, 2014 at 4:17 AM, Daria Mayorova wrote= : > Hi Neelesh, > > We are having some issues with the running topology, I described it here = =E2=80=93 > https://www.mail-archive.com/user@storm.incubator.apache.org/msg01655.htm= l > > We want to try using 0mq to check if replacing netty with it will make an= y > change. > > > On Sun, Apr 6, 2014 at 3:28 PM, Neelesh wrote: > >> Hi Daria, I'm curious about why you decided to go back to zmq instead of >> Netty. Did you hit any snags? >> >> >> On Fri, Apr 4, 2014 at 6:34 AM, Daria Mayorova wro= te: >> >>> Thanks for the info, Jon. >>> >>> You're right, I've found this repository =E2=80=93 >>> https://github.com/ptgoetz/storm-0mq. I guess this is what you meant. >>> I'll give it a try, let's see if I can make it work. >>> >>> >>> On Fri, Apr 4, 2014 at 2:58 PM, Jon Logan wrote: >>> >>>> You need to include the zeromq Storm binding in your storm lib folder >>>> probably...it's no longer packaged together due to GPL licensing issue= s. >>>> I've never done this, but I think it was broken off into a separate gi= thub >>>> repository. >>>> >>>> >>>> On Fri, Apr 4, 2014 at 7:01 AM, Daria Mayorova w= rote: >>>> >>>>> Thank you Susheel, >>>>> >>>>> We've tried to change this parameter, but the topology isn't >>>>> initializing. The following exception is returned: >>>>> >>>>> 2014-04-04 10:35:28 b.s.d.worker [ERROR] Error on initialization of >>>>> server mk-worker >>>>> java.lang.RuntimeException: Fail to construct messaging plugin from >>>>> plugin backtype.storm.messaging.zmq >>>>> at >>>>> backtype.storm.messaging.TransportFactory.makeContext(TransportFactor= y.java:53) >>>>> ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating] >>>>> at >>>>> backtype.storm.daemon.worker$worker_data$fn__4263.invoke(worker.clj:1= 85) >>>>> ~[na:0.9.1-incubating] >>>>> at backtype.storm.util$assoc_apply_self.invoke(util.clj:792) >>>>> ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating] >>>>> at >>>>> backtype.storm.daemon.worker$worker_data.invoke(worker.clj:181) >>>>> ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating] >>>>> at >>>>> backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414.inv= oke(worker.clj:353) >>>>> ~[na:0.9.1-incubating] >>>>> at clojure.lang.AFn.applyToHelper(AFn.java:185) >>>>> [clojure-1.4.0.jar:na] >>>>> at clojure.lang.AFn.applyTo(AFn.java:151) >>>>> [clojure-1.4.0.jar:na] >>>>> at clojure.core$apply.invoke(core.clj:601) >>>>> ~[clojure-1.4.0.jar:na] >>>>> at >>>>> backtype.storm.daemon.worker$eval4413$mk_worker__4469.doInvoke(worker= .clj:344) >>>>> [na:0.9.1-incubating] >>>>> at clojure.lang.RestFn.invoke(RestFn.java:512) >>>>> [clojure-1.4.0.jar:na] >>>>> at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) >>>>> [na:0.9.1-incubating] >>>>> at clojure.lang.AFn.applyToHelper(AFn.java:172) >>>>> [clojure-1.4.0.jar:na] >>>>> at clojure.lang.AFn.applyTo(AFn.java:151) >>>>> [clojure-1.4.0.jar:na] >>>>> at backtype.storm.daemon.worker.main(Unknown Source) >>>>> [storm-core-0.9.1-incubating.jar:0.9.1-incubating] >>>>> Caused by: java.lang.ClassNotFoundException: >>>>> backtype.storm.messaging.zmq >>>>> at java.net.URLClassLoader$1.run(URLClassLoader.java:217) >>>>> ~[na:1.6.0_27] >>>>> at java.security.AccessController.doPrivileged(Native Method) >>>>> ~[na:1.6.0_27] >>>>> at java.net.URLClassLoader.findClass(URLClassLoader.java:205) >>>>> ~[na:1.6.0_27] >>>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:321) >>>>> ~[na:1.6.0_27] >>>>> at >>>>> sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.= 6.0_27] >>>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:266) >>>>> ~[na:1.6.0_27] >>>>> at java.lang.Class.forName0(Native Method) ~[na:1.6.0_27] >>>>> at java.lang.Class.forName(Class.java:188) ~[na:1.6.0_27] >>>>> at >>>>> backtype.storm.messaging.TransportFactory.makeContext(TransportFactor= y.java:38) >>>>> ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating] >>>>> ... 13 common frames omitted >>>>> 2014-04-04 10:35:28 b.s.util [INFO] Halting process: ("Error on >>>>> initialization") >>>>> >>>>> 0mq and jzmq are installed correctly on the machine, as before Storm >>>>> 0.8.1 was running on it using 0mq. >>>>> >>>>> Any other thing that should be done to make this work? >>>>> >>>>> >>>>> On Fri, Apr 4, 2014 at 10:52 AM, Susheel Kumar Gadalay < >>>>> skgadalay@gmail.com> wrote: >>>>> >>>>>> Set this parameter in storm.yaml >>>>>> >>>>>> storm.messaging.transport: "backtype.storm.messaging.zmq" >>>>>> >>>>>> On 4/4/14, Daria Mayorova wrote: >>>>>> > Hi everyone, >>>>>> > >>>>>> > I am wondering whether it is possible to go back to using 0mq as >>>>>> transport >>>>>> > instead of Netty? I am pretty sure I saw some messages about >>>>>> switching back >>>>>> > to 0mq in Storm 0.9.1 at the old storm-user google group. >>>>>> > There is an issue related to this on Jira - >>>>>> > https://issues.apache.org/jira/browse/STORM-215 - but it seems to >>>>>> be >>>>>> > abandoned. >>>>>> > >>>>>> > Can anybody give me an idea of how this can be achieved? >>>>>> > >>>>>> > Thanks. >>>>>> > >>>>>> > Best regards, >>>>>> > Daria >>>>>> > >>>>>> >>>>> >>>>> >>>> >>> >> > --047d7bf0c12225e29d04f83b8fc4 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi all,

Stumbled upon this thread when = trying to switch to zeromq and came across this error after putting the sto= rm-0mq to <STORM_HOME>/lib directory.

java.lang.ExceptionInInitializerError: null
at java.lang.Class.forName0(Native Method) ~[= na:1.6.0_45]
a= t java.lang.Class.forName(Class.java:249) ~[na:1.6.0_45]
at clojure.lang.RT.= loadClassForName(RT.java:2056) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.load(RT.java:41= 9) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.= load(RT.java:400) ~[clojure-1.4.0.jar:na]
at clojure.core$load$fn__4890.invoke(core.clj:= 5415) ~[clojure-1.4.0.jar:na]
at clojure.core$loa= d.doInvoke(core.clj:5414) ~[clojure-1.4.0.jar:na]
at clojure.lang.RestFn.invoke(RestFn.ja= va:408) [clojure-1.4.0.jar:na]
at clojure.lang.Var= .invoke(Var.java:415) ~[clojure-1.4.0.jar:na]
at backtype.storm.messaging.zmq.<clinit&= gt;(Unknown Source) ~[storm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT]
at java.lang.Class.= forName0(Native Method) ~[na:1.6.0_45]
at java.lang.Class.forName(Class.java:171) ~[na:1.= 6.0_45]
at backtype.storm.m= essaging.TransportFactory.makeContext(TransportFactory.java:38) ~[storm-cor= e-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSHOT]
at backtype.storm.daemon.worke= r$worker_data$fn__4263.invoke(worker.clj:185) ~[na:0.9.2-incubating-SNAPSHO= T]
at backtype.storm.u= til$assoc_apply_self.invoke(util.clj:792) ~[storm-core-0.9.2-incubating-SNA= PSHOT.jar:0.9.2-incubating-SNAPSHOT]
at backtype.storm.daemon.worker$worker_data.invoke(w= orker.clj:181) ~[storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-= SNAPSHOT]
at backtype.storm.d= aemon.worker$eval4413$exec_fn__1102__auto____4414.invoke(worker.clj:353) ~[= na:0.9.2-incubating-SNAPSHOT]
at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.= 4.0.jar:na]
at clojure.lang.AFn= .applyTo(AFn.java:151) [clojure-1.4.0.jar:na]
at clojure.core$apply.invoke(core.clj:601) = ~[clojure-1.4.0.jar:na]
at backtype.storm.d= aemon.worker$eval4413$mk_worker__4469.doInvoke(worker.clj:344) [na:0.9.2-in= cubating-SNAPSHOT]
at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.4.0.jar:na]<= /div>
at backtype.storm.d= aemon.worker$_main.invoke(worker.clj:454) [na:0.9.2-incubating-SNAPSHOT]
at clojure.lang.= AFn.applyToHelper(AFn.java:172) [clojure-1.4.0.jar:na]
at clojure.lang.AFn= .applyTo(AFn.java:151) [clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker.main(Unknow= n Source) [storm-core-0.9.2-incubating-SNAPSHOT.jar:0.9.2-incubating-SNAPSH= OT]
Caused by: java.lang.ClassNotFoundException: org.zeromq.ZMQ
= at java.net.URLClassLoad= er$1.run(URLClassLoader.java:202) ~[na:1.6.0_45]
at java.security.AccessController.doPriv= ileged(Native Method) ~[na:1.6.0_45]
at java.net.URLClas= sLoader.findClass(URLClassLoader.java:190) ~[na:1.6.0_45]
at java.lang.ClassLoader.loadCl= ass(ClassLoader.java:306) ~[na:1.6.0_45]
at sun.misc.Launche= r$AppClassLoader.loadClass(Launcher.java:301) ~[na:1.6.0_45]
at java.lang.ClassLoader.loa= dClass(ClassLoader.java:247) ~[na:1.6.0_45]
at java.lang.Class.= forName0(Native Method) ~[na:1.6.0_45]
at java.lang.Class.forName(Class.java:171) ~[na:1.= 6.0_45]
at backtype.storm.m= essaging.zmq$loading__4784__auto__.invoke(zmq.clj:1) ~[storm-0mq-0.9.0.jar:= 0.9.2-incubating-SNAPSHOT]
at backtype.storm.messaging.zmq__init.load(Unknown Source) ~[s= torm-0mq-0.9.0.jar:0.9.2-incubating-SNAPSHOT]
at backtype.storm.m= essaging.zmq__init.<clinit>(Unknown Source) ~[storm-0mq-0.9.0.jar:0.9= .2-incubating-SNAPSHOT]
... 26 common frames omitted

This got resolved after copying 'zmq.jar'= from=C2=A0/usr/local/share/java/ to the lib directory as well. There might= be other ways to resolve this issue other than copying the 'zmq.jar= 9;. Just shared in case it will be useful for someone who comes across a si= milar issue.

Thanks,
Lasantha


On Mon, Apr 7, 2014 at 4:17 AM= , Daria Mayorova <d.mayorova@gmail.com> wrote:
Hi Neelesh,=C2=A0

<= /div>
We are having some issues with the running topology, I described = it here =E2=80=93=C2=A0https://www.mail-archi= ve.com/user@storm.incubator.apache.org/msg01655.html

We want to try using 0mq to check if replacing netty wi= th it will make any change.=C2=A0


On = Sun, Apr 6, 2014 at 3:28 PM, Neelesh <neeleshs@gmail.com> w= rote:
Hi Daria, I'm curious a= bout why you decided to go back to zmq instead of Netty. Did you hit any sn= ags?


On = Fri, Apr 4, 2014 at 6:34 AM, Daria Mayorova <d.mayorova@gmail.com= > wrote:
Thanks for the info, Jon.
You're right, I've found this repository =E2=80= =93=C2=A0https://github.com/ptgoetz/storm-0mq. I guess this is what you meant. = I'll give it a try, let's see if I can make it work.


On Fri, Apr 4, 2014 at 2:58 PM, Jon Logan <jmlogan@buffalo.edu&g= t; wrote:
You need to include the zer= omq Storm binding in your storm lib folder probably...it's no longer pa= ckaged together due to GPL licensing issues. I've never done this, but = I think it was broken off into a separate github repository.


On Fri, Apr 4= , 2014 at 7:01 AM, Daria Mayorova <d.mayorova@gmail.com> = wrote:
Thank you Susheel,

=
We've tried to change this parameter, but the topology isn&#= 39;t initializing. The following exception is returned:

2014-04-04 10:35:28 b.s.d.worker [ERROR] Error on = initialization of server mk-worker
java.lang.RuntimeException: Fail to construct messaging plugin from pl= ugin backtype.storm.messaging.zmq
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at = backtype.storm.messaging.TransportFactory.makeContext(TransportFactory.java= :53) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm.daemon.worker$worker_dat= a$fn__4263.invoke(worker.clj:185) ~[na:0.9.1-incubating]
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 at backtype.storm.util$assoc_apply_self.invoke(util.cl= j:792) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm.daemon.worker$worker_dat= a.invoke(worker.clj:181) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating= ]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm.daemon.worker$eva= l4413$exec_fn__1102__auto____4414.invoke(worker.clj:353) ~[na:0.9.1-incubat= ing]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at clojure.lang.AFn.applyToHelper(AFn.java= :185) [clojure-1.4.0.jar:na]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at cloju= re.lang.AFn.applyTo(AFn.java:151) [clojure-1.4.0.jar:na]
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 at clojure.core$apply.invoke(core.clj:601) ~[clojure-1= .4.0.jar:na]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm.daemon.worker$eval4413$m= k_worker__4469.doInvoke(worker.clj:344) [na:0.9.1-incubating]
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at clojure.lang.RestFn.invoke(RestFn.java:512) [cl= ojure-1.4.0.jar:na]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm= .daemon.worker$_main.invoke(worker.clj:454) [na:0.9.1-incubating]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at clojure.lang.AFn.applyToHelper(AFn.java= :172) [clojure-1.4.0.jar:na]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at cloju= re.lang.AFn.applyTo(AFn.java:151) [clojure-1.4.0.jar:na]
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 at backtype.storm.daemon.worker.main(Unknown Source) [= storm-core-0.9.1-incubating.jar:0.9.1-incubating]
Caused by: java.lang.ClassNotFoundException: backtype.storm.messaging.= zmq
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.net.URLClassLoader$1.run(= URLClassLoader.java:217) ~[na:1.6.0_27]
=C2=A0 =C2=A0 =C2=A0 =C2= =A0 at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.= 0_27]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.net.URLClassLoader.findClass(URLCl= assLoader.java:205) ~[na:1.6.0_27]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at= java.lang.ClassLoader.loadClass(ClassLoader.java:321) ~[na:1.6.0_27]
=
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.misc.Launcher$AppClassLoader.loadCl= ass(Launcher.java:294) ~[na:1.6.0_27]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.ClassLoader.loadClass(ClassLo= ader.java:266) ~[na:1.6.0_27]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java= .lang.Class.forName0(Native Method) ~[na:1.6.0_27]
=C2=A0 =C2=A0 = =C2=A0 =C2=A0 at java.lang.Class.forName(Class.java:188) ~[na:1.6.0_27]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at backtype.storm.messaging.TransportFacto= ry.makeContext(TransportFactory.java:38) ~[storm-core-0.9.1-incubating.jar:= 0.9.1-incubating]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 ... 13 common frame= s omitted
2014-04-04 10:35:28 b.s.util [INFO] Halting process: (&= quot;Error on initialization")

0mq and jzmq are installed correctly on the machi= ne, as before Storm 0.8.1 was running on it using 0mq.

=
Any other thing that should be done to make this work?


On Fri, Apr 4= , 2014 at 10:52 AM, Susheel Kumar Gadalay <skgadalay@gmail.com> wrote:
Set this parameter in storm.yaml

storm.messaging.transport: "backtype.storm.messaging.zmq"

On 4/4/14, Daria Mayorova <d.mayorova@gmail.com> wrote:
> Hi everyone,
>
> I am wondering whether it is possible to go back to using 0mq as trans= port
> instead of Netty? I am pretty sure I saw some messages about switching= back
> to 0mq in Storm 0.9.1 at the old storm-user google group.
> There is an issue related to this on Jira -
> https://issues.apache.org/jira/browse/STORM-215 - but= it seems to be
> abandoned.
>
> Can anybody give me an idea of how this can be achieved?
>
> Thanks.
>
> Best regards,
> Daria
>






--047d7bf0c12225e29d04f83b8fc4--