Hello! I trying to run storm-starter TridentWordCount example on Storm
0.10.0. I have next properties in storm.yaml:
storm.local.dir: "/tmp/storm-data"
storm.zookeeper.servers:
- "ub1simpl510"
storm.zookeeper.port: 5181
nimbus.host: "ub1simpl510"
ui.port: 8081
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
storm.thrift.transport:
"backtype.storm.security.auth.kerberos.KerberosSaslTransportPlugin"
java.security.auth.login.config: "pathToMyConf"
java.security.krb5.conf: "/etc/krb5.conf"
storm.principal.tolocal:
"backtype.storm.security.auth.KerberosPrincipalToLocal"
storm.zookeeper.superACL: "sasl:validPrincipal
nimbus.authorizer:
"backtype.storm.security.auth.authorizer.SimpleACLAuthorizer"
But when I trying to start topology, I have exception:
5167 [main] INFO b.s.d.supervisor - Starting supervisor with id
9065b694-b4a1-4dbe-913e-d098d9b8d2e6 at host localhost
5388 [main] INFO b.s.d.nimbus - [req 1] Access from: principal:
op:submitTopology
5389 [main] INFO b.s.s.a.a.SimpleACLAuthorizer - [req 1] Access from:
null op:submitTopology topoology:wordCounter
5392 [main] WARN b.s.d.nimbus - Topology submission exception. (topology
name='wordCounter') #<NullPointerException java.lang.NullPointerException>
5393 [main] ERROR o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Thread
Thread[main,5,main] died
java.lang.NullPointerException
at
backtype.storm.security.auth.authorizer.SimpleACLAuthorizer.permit(SimpleACLAuthorizer.java:99)
~[storm-core-0.10.0.jar:0.10.0]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.7.0_79]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
~[?:1.7.0_79]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.7.0_79]
at java.lang.reflect.Method.invoke(Method.java:606) ~[?:1.7.0_79]
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
~[clojure-1.6.0.jar:?]
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
~[clojure-1.6.0.jar:?]
at
backtype.storm.daemon.nimbus$check_authorization_BANG_.invoke(nimbus.clj:797)
~[storm-core-0.10.0.jar:0.10.0]
at
backtype.storm.daemon.nimbus$check_authorization_BANG_.invoke(nimbus.clj:801)
~[storm-core-0.10.0.jar:0.10.0]
at
backtype.storm.daemon.nimbus$fn__4120$exec_fn__1978__auto__$reify__4135.submitTopologyWithOpts(nimbus.clj:1048)
~[storm-core-0.10.0.jar:0.10.0]
at
backtype.storm.daemon.nimbus$fn__4120$exec_fn__1978__auto__$reify__4135.submitTopology(nimbus.clj:1119)
~[storm-core-0.10.0.jar:0.10.0]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.7.0_79]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
~[?:1.7.0_79]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.7.0_79]
at java.lang.reflect.Method.invoke(Method.java:606) ~[?:1.7.0_79]
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
~[clojure-1.6.0.jar:?]
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
~[clojure-1.6.0.jar:?]
at backtype.storm.testing$submit_local_topology.invoke(testing.clj:276)
~[storm-core-0.10.0.jar:0.10.0]
at backtype.storm.LocalCluster$_submitTopology.invoke(LocalCluster.clj:43)
~[storm-core-0.10.0.jar:0.10.0]
at backtype.storm.LocalCluster.submitTopology(Unknown Source)
~[storm-core-0.10.0.jar:0.10.0]
at storm.starter.trident.TridentWordCount.main(TridentWordCount.java:74)
~[storm-starter-topologies-0.10.0.jar:0.10.0]
It's looks like principal is null. But I have successfully logged in via
kinit command.
Please, help me to solve this problem!
