Hello,
I'm new to Apache Storm, and have run into some trouble running the
storm-starter ExclamationTopology example. I'm running on a MacBookPro with
Mojave, I've downloaded and installed the Storm binary tar, and generated
the storm-starter uber-jar with no (obvious) errors. When I run locally
with the following command:
storm jar storm-starter-1.2.2.jar
org.apache.storm.starter.ExclamationTopology
I get alot of output; bracketing the Local processing in main...
*else* {
LocalCluster cluster = *new* LocalCluster();
System.*out*.println("Starting Topology......");
cluster.submitTopology("test", conf, builder.createTopology());
System.*out*.println("Ending Topology......");
Utils.*sleep*(10000);
cluster.killTopology("test");
cluster.shutdown();
}
isolates the following info/error:
Starting Topology......
48124 [main] WARN o.a.s.u.Utils - STORM-VERSION new 1.2.2 old null
48129 [main] WARN o.a.s.u.Utils - STORM-VERSION new 1.2.2 old 1.2.2
48166 [main] INFO o.a.s.d.nimbus - Received topology submission for test
(storm-1.2.2 JDK-1.8.0_211) with conf {"topology.max.task.parallelism" nil,
"topology.submitter.principal" "", "topology.acker.executors" nil,
"topology.eventlogger.executors" 0, "topology.debug" true,
"storm.zookeeper.superACL" nil, "topology.users" (),
"topology.submitter.user" "david", "topology.kryo.register" nil,
"topology.kryo.decorators" (), "storm.id" "test-1-1556727673", "
topology.name" "test"}
48172 [main] INFO o.a.s.d.nimbus - uploadedJar
48183 [ProcessThread(sid:0 cport:-1):] INFO
o.a.s.s.o.a.z.s.PrepRequestProcessor
- Got user-level KeeperException when processing
sessionid:0x16a7432a8950000 type:create cxid:0xb zxid:0x25 txntype:-1
reqpath:n/a Error Path:/storm/blobstoremaxkeysequencenumber
Error:KeeperErrorCode = NoNode for /storm/blobstoremaxkeysequencenumber
48189 [main] INFO o.a.s.cluster -
setup-path/blobstore/test-1-1556727673-stormconf.ser/192.168.241.5:6627-1
48207 [main] INFO o.a.s.cluster -
setup-path/blobstore/test-1-1556727673-stormcode.ser/192.168.241.5:6627-1
48215 [main] INFO o.a.s.d.nimbus - desired replication count 1 achieved,
current-replication-count for conf key = 1, current-replication-count for
code key = 1, current-replication-count for jar key = 1
48258 [main] INFO o.a.s.d.nimbus - Activating test: test-1-1556727673
Ending Topology......
I've searched, and it looks like information about the processing should
appear here instead. I haven't found anything specific to Storm concerning
this error. I have found references to it for Zookeeper, so tried
installing and running Zookeeper and Kafka, with no improvement; the Storm
tutorial didn't state this was required, but I thought I'd try anyway. At
this point, I've exhausted my guesses, and was hoping someone could help
point me in the proper direction. I appreciate any suggestions...
Dave H.
