Member since
10-22-2016
1
Post
1
Kudos Received
0
Solutions
10-22-2016
12:32 AM
1 Kudo
We enabled kerberos on the cluster, have enabled HA for nimbus and created the kerberos ticket on the commandline in the edgenode with appropriate rights in ranger for the principal. when running a sample topology of wordcount in this manner storm jar myStorm-0.0.1-SNAPSHOT.jar com.storm.test.myStorm.helloStorm /home/BBattin/storm_test/input.txt we are getting the following error Exception in thread "main" java.lang.RuntimeException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds
at backtype.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:90)
at backtype.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:225)
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:271)
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:157)
at com.storm.test.myStorm.helloStorm.main(helloStorm.java:24)
please help
... View more
Labels:
- Labels:
-
Apache Storm