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 <[email protected]> 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.
signature.asc
Description: Message signed with OpenPGP using GPGMail
