apache - storm-starter example topologies crash -

apache - storm-starter example topologies crash -

i getting started twitter storm framework on os x 10.9.5. however, running problem running illustration topologies in storm-starter: https://github.com/apache/storm/tree/master/examples/storm-starter.

following readme, seek deploy topology locally calling

sudo mvn exec:java -dstorm.topology=storm.starter.wordcounttopology

the topology runs less minute, , terminates in error:

[error] failed execute goal org.codehaus.mojo:exec-maven-plugin:1.2.1:java (default-cli) on project storm-starter: exception occured while executing java class. java.lang.interruptedexception -> [help 1] org.apache.maven.lifecycle.lifecycleexecutionexception: failed execute goal org.codehaus.mojo:exec-maven-plugin:1.2.1:java (default-cli) on project storm-starter: exception occured while executing java class. java.lang.interruptedexception @ org.apache.maven.lifecycle.internal.mojoexecutor.execute(mojoexecutor.java:216) @ org.apache.maven.lifecycle.internal.mojoexecutor.execute(mojoexecutor.java:153) @ org.apache.maven.lifecycle.internal.mojoexecutor.execute(mojoexecutor.java:145) @ org.apache.maven.lifecycle.internal.lifecyclemodulebuilder.buildproject(lifecyclemodulebuilder.java:116) @ org.apache.maven.lifecycle.internal.lifecyclemodulebuilder.buildproject(lifecyclemodulebuilder.java:80) @ org.apache.maven.lifecycle.internal.builder.singlethreaded.singlethreadedbuilder.build(singlethreadedbuilder.java:51) @ org.apache.maven.lifecycle.internal.lifecyclestarter.execute(lifecyclestarter.java:120) @ org.apache.maven.defaultmaven.doexecute(defaultmaven.java:347) @ org.apache.maven.defaultmaven.execute(defaultmaven.java:154) @ org.apache.maven.cli.mavencli.execute(mavencli.java:582) @ org.apache.maven.cli.mavencli.domain(mavencli.java:214) @ org.apache.maven.cli.mavencli.main(mavencli.java:158) @ sun.reflect.nativemethodaccessorimpl.invoke0(native method) @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:39) @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:25) @ java.lang.reflect.method.invoke(method.java:597) @ org.codehaus.plexus.classworlds.launcher.launcher.launchenhanced(launcher.java:289) @ org.codehaus.plexus.classworlds.launcher.launcher.launch(launcher.java:229) @ org.codehaus.plexus.classworlds.launcher.launcher.mainwithexitcode(launcher.java:415) @ org.codehaus.plexus.classworlds.launcher.launcher.main(launcher.java:356) caused by: org.apache.maven.plugin.mojoexecutionexception: exception occured while executing java class. java.lang.interruptedexception @ org.codehaus.mojo.exec.execjavamojo.execute(execjavamojo.java:352) @ org.apache.maven.plugin.defaultbuildpluginmanager.executemojo(defaultbuildpluginmanager.java:132) @ org.apache.maven.lifecycle.internal.mojoexecutor.execute(mojoexecutor.java:208) ... 19 more caused by: java.lang.runtimeexception: java.lang.interruptedexception @ backtype.storm.util$wrap_in_runtime.invoke(util.clj:44) @ backtype.storm.zookeeper$exists_node_qmark_$fn__907.invoke(zookeeper.clj:102) @ backtype.storm.zookeeper$exists_node_qmark_.invoke(zookeep`enter code here`er.clj:98) @ backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:114) @ backtype.storm.cluster$mk_distributed_cluster_state$reify__1757.mkdirs(cluster.clj:119) @ backtype.storm.cluster$mk_storm_cluster_state$reify__2214.report_error(cluster.clj:397) @ backtype.storm.daemon.executor$throttled_report_error_fn$fn__3547.invoke(executor.clj:179) @ backtype.storm.daemon.executor$fn__3767$fn$reify__3812.reporterror(executor.clj:737) @ backtype.storm.task.outputcollector.reporterror(outputcollector.java:223) @ backtype.storm.task.shellbolt.die(shellbolt.java:303) @ backtype.storm.task.shellbolt.access$800(shellbolt.java:68) @ backtype.storm.task.shellbolt$1.run(shellbolt.java:137) @ java.lang.thread.run(thread.java:695) caused by: java.lang.interruptedexception @ java.lang.object.wait(native method) @ java.lang.object.wait(object.java:485) @ org.apache.storm.zookeeper.clientcnxn.submitrequest(clientcnxn.java:1342) @ org.apache.storm.zookeeper.zookeeper.exists(zookeeper.java:1040) @ org.apache.storm.curator.framework.imps.existsbuilderimpl$2.call(existsbuilderimpl.java:172) @ org.apache.storm.curator.framework.imps.existsbuilderimpl$2.call(existsbuilderimpl.java:161) @ org.apache.storm.curator.retryloop.callwithretry(retryloop.java:107) @ org.apache.storm.curator.framework.imps.existsbuilderimpl.pathinforeground(existsbuilderimpl.java:157) @ org.apache.storm.curator.framework.imps.existsbuilderimpl.forpath(existsbuilderimpl.java:148) @ org.apache.storm.curator.framework.imps.existsbuilderimpl.forpath(existsbuilderimpl.java:36) @ backtype.storm.zookeeper$exists_node_qmark_$fn__907.invoke(zookeeper.clj:101) ... 11 more

any help appreciated.

i believe issue seeing result of cluster shutdown:

see [./src/jvm/storm/starter/wordcounttopology.java]:

... else { conf.setmaxtaskparallelism(3); localcluster cluster = new localcluster(); cluster.submittopology("word-count", conf, builder.createtopology()); thread.sleep(10000); //<----- here cluster.shutdown(); //<----- here }

apache distributed-computing apache-storm