You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Richards Peter <hb...@gmail.com> on 2014/08/04 14:46:28 UTC

storm-0.9.2-incubating topology submission fails

Hi,

I am trying to migrate to storm-0.9.2-incubating from storm-0.8.2. With
storm-0.8.2 I submit topology as per the following post:

https://groups.google.com/forum/?fromgroups#!searchin/storm-user/Can$20we$20submit$20the$20topology$20jar$20without$20using$20storm$20command$3F/storm-user/5JjZQyviRqk/B_r1Ybew4aYJ

However when I use the same code with storm-0.9.2, I get the following
error when I submit the topology. Could anyone tell me what I am missing?

java.lang.RuntimeException: java.lang.NullPointerException
        at
backtype.storm.security.auth.AuthUtils.GetTransportPlugin(AuthUtils.java:78)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at
backtype.storm.security.auth.ThriftClient.<init>(ThriftClient.java:47)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:47)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:43)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at
backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:36)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:235)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
        at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:220)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]

Regards,
Richards Peter.

Re: storm-0.9.2-incubating topology submission fails

Posted by Richards Peter <hb...@gmail.com>.

Thanks Taylor.
I will check it out.

Richards Peter.

Re: storm-0.9.2-incubating topology submission fails

Posted by "P. Taylor Goetz" <pt...@gmail.com>.

I take it you are using the Nimbus client directly to submit the topology, rather than using the `storm jar` command.

If that’s the case, you need to configure the transport plugin:

        Map<String, Object> conf = new HashMap<String, Object>();
        conf.put("storm.thrift.transport", "backtype.storm.security.auth.SimpleTransportPlugin");

        NimbusClient nc = NimbusClient.getConfiguredClient(conf);


- Taylor

On Aug 4, 2014, at 8:46 AM, Richards Peter <hb...@gmail.com> wrote:

> Hi,
> 
> I am trying to migrate to storm-0.9.2-incubating from storm-0.8.2. With storm-0.8.2 I submit topology as per the following post:
> 
> https://groups.google.com/forum/?fromgroups#!searchin/storm-user/Can$20we$20submit$20the$20topology$20jar$20without$20using$20storm$20command$3F/storm-user/5JjZQyviRqk/B_r1Ybew4aYJ
> 
> However when I use the same code with storm-0.9.2, I get the following error when I submit the topology. Could anyone tell me what I am missing?
> 
> java.lang.RuntimeException: java.lang.NullPointerException
>         at backtype.storm.security.auth.AuthUtils.GetTransportPlugin(AuthUtils.java:78) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.security.auth.ThriftClient.<init>(ThriftClient.java:47) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:47) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:43) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:36) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:235) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
>         at backtype.storm.StormSubmitter.submitJar(StormSubmitter.java:220) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
> 
> Regards,
> Richards Peter.