You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Chandrahas Gurram <ch...@peel.com> on 2014/08/08 07:37:43 UTC
Storm submit problem
Hi,
I am trying to submit my jar to nimbus using the command storm jar
pathtofile mainclassname arguments.
it is throwing connection refused error. can anyone help me with this issue
ThankYou,
G V Chandrahas Raj
Re: Storm submit problem
Posted by Chandrahas Gurram <ch...@peel.com>.
1262 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to
master yet. Submitting jar...
1772 [main] INFO backtype.storm.StormSubmitter - Uploading topology jar
<my jar path> to assigned location:
/mnt/storm/nimbus/inbox/stormjar-097f2024-b581-4413-b6c8-5b4431f3309e.jar
Exception in thread "main" java.lang.RuntimeException:
org.apache.thrift7.transport.TTransportException: java.net.SocketException:
Connection reset
at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:164)
at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:140)
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:91)
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:58)
at com.peel.kinesisStorm.SampleTopology.main(SampleTopology.java:91)
Caused by: org.apache.thrift7.transport.TTransportException:
java.net.SocketException: Connection reset
at
org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:129)
at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift7.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
at
org.apache.thrift7.transport.TFramedTransport.read(TFramedTransport.java:101)
at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift7.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
at
org.apache.thrift7.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
at
org.apache.thrift7.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:69)
at
backtype.storm.generated.Nimbus$Client.recv_uploadChunk(Nimbus.java:361)
at backtype.storm.generated.Nimbus$Client.uploadChunk(Nimbus.java:347)
at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:158)
... 4 more
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(SocketInputStream.java:196)
at java.net.SocketInputStream.read(SocketInputStream.java:122)
at
org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:127)
... 15 more
ThankYou,
G V Chandrahas Raj
On Fri, Aug 8, 2014 at 4:17 PM, Babu, Prashanth <Pr...@nttdata.com>
wrote:
> Can you show us the full stacktrace of the error you are getting.
>
>
>
> *From:* Chandrahas Gurram [mailto:chandrahas.g@peel.com]
> *Sent:* 08 August 2014 07:17
> *To:* user@storm.incubator.apache.org
> *Subject:* Re: Storm submit problem
>
>
>
> yes they are up.
>
>
>
> ThankYou,
> G V Chandrahas Raj
>
>
>
> On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi <
> padmapriya30@gmail.com> wrote:
>
> Have u started nimbus , supervisor and zookeeper ?
>
>
>
> On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <ch...@peel.com>
> wrote:
>
> Hi,
>
> I am trying to submit my jar to nimbus using the command storm jar
> pathtofile mainclassname arguments.
>
> it is throwing connection refused error. can anyone help me with this issue
>
>
> ThankYou,
> G V Chandrahas Raj
>
>
>
>
>
> ______________________________________________________________________
> Disclaimer:This email and any attachments are sent in strictest confidence
> for the sole use of the addressee and may contain legally privileged,
> confidential, and proprietary data. If you are not the intended recipient,
> please advise the sender by replying promptly to this email and then delete
> and destroy this email and any attachments without any further use, copying
> or forwarding
>
RE: Storm submit problem
Posted by "Babu, Prashanth" <Pr...@nttdata.com>.
Can you show us the full stacktrace of the error you are getting.
From: Chandrahas Gurram [mailto:chandrahas.g@peel.com]
Sent: 08 August 2014 07:17
To: user@storm.incubator.apache.org
Subject: Re: Storm submit problem
yes they are up.
ThankYou,
G V Chandrahas Raj
On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi <pa...@gmail.com>> wrote:
Have u started nimbus , supervisor and zookeeper ?
On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <ch...@peel.com>> wrote:
Hi,
I am trying to submit my jar to nimbus using the command storm jar pathtofile mainclassname arguments.
it is throwing connection refused error. can anyone help me with this issue
ThankYou,
G V Chandrahas Raj
______________________________________________________________________
Disclaimer:This email and any attachments are sent in strictest confidence for the sole use of the addressee and may contain legally privileged, confidential, and proprietary data. If you are not the intended recipient, please advise the sender by replying promptly to this email and then delete and destroy this email and any attachments without any further use, copying or forwarding
Re: Storm submit problem
Posted by Spico Florin <sp...@gmail.com>.
Hello!
By default when you are sending your jar file to the nimbus, with the
"storm jar" command the default host for nimbus is localhost. If you'd like
to specify a different one you can say something like:
storm jar <your_jar> <your_toplogy_class_name> <top_name> -c
nimbus.host=<ip of your nimbus>
A different solution is to create a folder named .storm in /home/your_user
and create a file storm.yaml that contains the following line:
nimbus.host: "IP of your nimbus machine"
With this solution you are not force to provide the nimbus.host in the
storm jar command.
By Nimbus process is listening on port 6627. Check if this port is open. Do
you have firewall? If yes, open the mentioned port in iptables.
Hope that these help.
Regards,
Florin
On Sat, Aug 9, 2014 at 10:21 AM, Yaron Rosenbaum <ya...@gmail.com>
wrote:
> Are you using a VM / VirtualBox / Docker containers by any chance?
> If so, what is the nimbus port?
>
> (Y)
>
> On Aug 8, 2014, at 9:16 AM, Chandrahas Gurram <ch...@peel.com>
> wrote:
>
> yes they are up.
>
>
> ThankYou,
> G V Chandrahas Raj
>
>
> On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi <
> padmapriya30@gmail.com> wrote:
>
>> Have u started nimbus , supervisor and zookeeper ?
>>
>>
>> On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <
>> chandrahas.g@peel.com> wrote:
>>
>>> Hi,
>>>
>>> I am trying to submit my jar to nimbus using the command storm jar
>>> pathtofile mainclassname arguments.
>>> it is throwing connection refused error. can anyone help me with this
>>> issue
>>>
>>>
>>> ThankYou,
>>> G V Chandrahas Raj
>>>
>>
>>
>
>
Re: Storm submit problem
Posted by Yaron Rosenbaum <ya...@gmail.com>.
Are you using a VM / VirtualBox / Docker containers by any chance?
If so, what is the nimbus port?
(Y)
On Aug 8, 2014, at 9:16 AM, Chandrahas Gurram <ch...@peel.com> wrote:
> yes they are up.
>
>
> ThankYou,
> G V Chandrahas Raj
>
>
> On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi <pa...@gmail.com> wrote:
> Have u started nimbus , supervisor and zookeeper ?
>
>
> On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <ch...@peel.com> wrote:
> Hi,
>
> I am trying to submit my jar to nimbus using the command storm jar pathtofile mainclassname arguments.
> it is throwing connection refused error. can anyone help me with this issue
>
>
> ThankYou,
> G V Chandrahas Raj
>
>
Re: Storm submit problem
Posted by Chandrahas Gurram <ch...@peel.com>.
yes they are up.
ThankYou,
G V Chandrahas Raj
On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi <
padmapriya30@gmail.com> wrote:
> Have u started nimbus , supervisor and zookeeper ?
>
>
> On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <chandrahas.g@peel.com
> > wrote:
>
>> Hi,
>>
>> I am trying to submit my jar to nimbus using the command storm jar
>> pathtofile mainclassname arguments.
>> it is throwing connection refused error. can anyone help me with this
>> issue
>>
>>
>> ThankYou,
>> G V Chandrahas Raj
>>
>
>
Re: Storm submit problem
Posted by padma priya chitturi <pa...@gmail.com>.
Have u started nimbus , supervisor and zookeeper ?
On Fri, Aug 8, 2014 at 11:07 AM, Chandrahas Gurram <ch...@peel.com>
wrote:
> Hi,
>
> I am trying to submit my jar to nimbus using the command storm jar
> pathtofile mainclassname arguments.
> it is throwing connection refused error. can anyone help me with this issue
>
>
> ThankYou,
> G V Chandrahas Raj
>