I'm trying to understand the Zk interaction, is it trying to really run on
127.0.0.1?
3959 [main] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x155fffd30df0004
closed
3959 [main] INFO b.s.u.StormBoundedExponentialBackoffRetry - The
baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]
3960 [main] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting
3960 [main] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection,
connectString=localhost:2000/storm sessionTimeout=20000
watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@3724b43e
3960 [main-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn -
Opening socket connection to server localhost/127.0.0.1:2000. Will not
attempt to authenticate using SASL (unknown error)
3961 [main-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn -
Socket connection established to localhost/127.0.0.1:2000, initiating
session
3961 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO
o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /
127.0.0.1:41592
3961 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO
o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new
session at /127.0.0.1:41592
3962 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established
session 0x155fffd30df0005 with negotiated timeout 20000 for client /
127.0.0.1:41592
My configuration (storm.yaml) is the following:
storm.zookeeper.servers:
- "zookeeper-stormcluster.gobalto.com"
nimbus.host: "nimbus-stormcluster.gobalto.com"
nimbus.childopts: "-Xmx1024m -Djava.net.preferIPv4Stack=true"
ui.childopts: "-Xmx768m -Djava.net.preferIPv4Stack=true"
supervisor.childopts: "-Djava.net.preferIPv4Stack=true"
worker.childopts: "-Xmx768m -Djava.net.preferIPv4Stack=true"
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
# netty transport
storm.messaging.transport: "backtype.storm.messaging.netty.Context"
storm.messaging.netty.buffer_size: 16384
storm.messaging.netty.max_retries: 10
storm.messaging.netty.min_wait_ms: 1000
storm.messaging.netty.max_wait_ms: 5000
drpc.servers:
- "nimbus-stormcluster.gobalto.com"
storm.local.dir: "/app/storm"
--
是故勝兵先勝而後求戰，敗兵先戰而後求勝。
