AnsweredAssumed Answered

can not start storm on mapr

Question asked by danielzhou on Mar 11, 2016
Latest reply on Mar 15, 2016 by danielzhou

I followed this link and install storm on my two-node cluster:

Storm (0.9.3-1501 and 0.9.4) - MapR 5.0 Documentation - doc.mapr.com

And I configured the "storm.yaml" in both nodes.

But I could not start it successfully:

 

Here is the log info:

 

2016-03-11 13:20:57.337 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/0:0:0:0:0:0:0:1:5181. Will not attempt to authenticate using SASL (unknown error)

2016-03-11 13:20:57.338 o.a.s.s.o.a.z.ClientCnxn [WARN] Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect

java.net.ConnectException: Connection refused

  at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.7.0_67]

  at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) ~[?:1.7.0_67]

  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1070) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

2016-03-11 13:20:57.440 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:5181. Will not attempt to authenticate using SASL (unknown error)

2016-03-11 13:20:57.441 o.a.s.s.o.a.z.ClientCnxn [WARN] Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect

java.net.ConnectException: Connection refused

  at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.7.0_67]

  at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) ~[?:1.7.0_67]

  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1070) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

2016-03-11 13:20:57.442 b.s.d.supervisor [ERROR] Error on initialization of server mk-supervisor

java.lang.RuntimeException: org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /storm

  at backtype.storm.util$wrap_in_runtime.invoke(util.clj:49) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.zookeeper$exists_node_QMARK_$fn__2616.invoke(zookeeper.clj:103) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:99) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:115) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.cluster$mk_distributed_cluster_state.doInvoke(cluster.clj:55) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.RestFn.invoke(RestFn.java:486) ~[clojure-1.6.0.jar:?]

  at backtype.storm.cluster$mk_storm_cluster_state.doInvoke(cluster.clj:272) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.RestFn.invoke(RestFn.java:439) ~[clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor$supervisor_data.invoke(supervisor.clj:295) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.daemon.supervisor$fn__5650$exec_fn__1978__auto____5651.invoke(supervisor.clj:499) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.AFn.applyToHelper(AFn.java:160) ~[clojure-1.6.0.jar:?]

  at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?]

  at clojure.core$apply.invoke(core.clj:624) ~[clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor$fn__5650$mk_supervisor__5677.doInvoke(supervisor.clj:495) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.RestFn.invoke(RestFn.java:436) [clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor$_launch.invoke(supervisor.clj:785) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.daemon.supervisor$_main.invoke(supervisor.clj:816) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.AFn.applyToHelper(AFn.java:152) [clojure-1.6.0.jar:?]

  at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor.main(Unknown Source) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

Caused by: org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /storm

  at org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:99) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:51) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:1041) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuilderImpl.java:226) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuilderImpl.java:215) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.pathInForegroundStandard(ExistsBuilderImpl.java:212) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:205) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:168) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:39) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.zookeeper$exists_node_QMARK_$fn__2616.invoke(zookeeper.clj:102) ~[storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  ... 18 more

2016-03-11 13:20:57.458 b.s.util [ERROR] Halting process: ("Error on initialization")

java.lang.RuntimeException: ("Error on initialization")

  at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:336) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor$fn__5650$mk_supervisor__5677.doInvoke(supervisor.clj:495) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.RestFn.invoke(RestFn.java:436) [clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor$_launch.invoke(supervisor.clj:785) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at backtype.storm.daemon.supervisor$_main.invoke(supervisor.clj:816) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

  at clojure.lang.AFn.applyToHelper(AFn.java:152) [clojure-1.6.0.jar:?]

  at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:?]

  at backtype.storm.daemon.supervisor.main(Unknown Source) [storm-core-0.10.0-mapr-1602.jar:0.10.0-mapr-1602]

Outcomes