Which storm version are you using? I remember, I faced this error once, and I changed the release to fix the issue.
Cheers, Anis On Wed, Jan 21, 2015 at 7:03 AM, Kosala Dissanayake <[email protected]> wrote: > The worker *is *running. > > The worker process is writing that log about the Reconnect. It's > complaining that it cannot connect to 192.168.6.88 port 6701. > > Check if the IP address and port are accessible from the machine on which > the log is being written. *You probably need to open your ports 6700-6703 > on your supervisor machines. * > > On Wed, Jan 21, 2015 at 4:50 PM, siddharth ubale < > [email protected]> wrote: > >> Hi, >> >> I checked the logs where it was mentioned >> >> "Worker c7c36c15-17d6-49d3-9cfb-6b00543bc117 for storm >> kafka-storm-Phoenix-ClusterD-1-1421763749 on >> d1fbe85d-6d15-47c9-9c69-5cc738ca1937:6700 has finished loading >> 2015-01-20T19:52:36.234+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [6] >> 2015-01-20T19:52:36.431+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [7] >> 2015-01-20T19:52:36.743+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [8] >> 2015-01-20T19:52:37.101+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [9] >> 2015-01-20T19:52:37.462+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [10] >> 2015-01-20T19:52:37.824+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [11] >> 2015-01-20T19:52:38.189+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [12] >> 2015-01-20T19:52:38.555+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [13] >> 2015-01-20T19:52:38.925+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [14] >> 2015-01-20T19:52:39.295+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [15] >> 2015-01-20T19:52:39.668+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [16] >> 2015-01-20T19:52:40.043+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [17] >> 2015-01-20T19:52:40.420+0530 b.s.m.n.Client [INFO] Reconnect started for >> Netty-Client-dwh3/192.168.6.88:6701... [18]" >> >> the reconnect message in log is constant. >> >> I asssumed that the worker is not running as expected. >> Any thoughts? >> >> Thanks, >> Siddharth >> >> On Wed, Jan 21, 2015 at 9:55 AM, Kosala Dissanayake <[email protected] >> > wrote: >> >>> Hi Siddharth, >>> >>> How did you come to the conclusion that the supervisors and workers have >>> not started? Did you open the ports 6700-6703 on the supervisor machines? >>> >>> Cheers, >>> Kosala >>> >>> >>> >>> On Wed, Jan 21, 2015 at 1:25 AM, siddharth ubale < >>> [email protected]> wrote: >>> >>>> Hi, >>>> >>>> I am runnning a Kafka-storm topology . >>>> >>>> The topology works exactly as expected in LocalCluster mode. However in >>>> Distributed mode the Workers are not starting , supervisor has not started. >>>> Only nimbus starts >>>> >>>> I am trying to run the topology via eclipse. >>>> >>>> //Providing the details for zkHosts >>>> BrokerHosts hosts = new ZkHosts("hbase:2181","/brokers"); >>>> SpoutConfig spoutconf = new >>>> SpoutConfig(hosts,TOPIC_NAME,"/test101","sid"); >>>> spoutconf.scheme = new SchemeAsMultiScheme(new StringScheme()); >>>> spoutconf.forceFromStart = true; >>>> KafkaSpout Kspout = new KafkaSpout(spoutconf); >>>> builder.setSpout("spout", Kspout, 1); >>>> >>>> PhoenixBolt phoenixBolt = new PhoenixBolt("Phoenix-Bolt", true,true,new >>>> Fields("json")); >>>> builder.setBolt("Phoenix-Bolt", phoenixBolt, >>>> 1).shuffleGrouping("spout"); >>>> >>>> Config config = new Config(); >>>> >>>> config.put(Config.NIMBUS_THRIFT_PORT,6627); >>>> config.put(Config.STORM_ZOOKEEPER_PORT,2181); >>>> config.put(Config.STORM_ZOOKEEPER_SERVERS,Arrays.asList(new >>>> String[]{"hbase"})); >>>> config.put(Config.NIMBUS_HOST, "dwh3"); >>>> config.put("storm.zookeeper.root","/storm1"); >>>> config.put(Config.STORM_ZOOKEEPER_ROOT, "/storm1"); >>>> >>>> System.setProperty("storm.jar","/usr/local/apache-storm-0.9.3/bin/storm"); >>>> config.setDebug(true); >>>> config.setNumWorkers(5); >>>> config.put(Config.TOPOLOGY_DEBUG, true); >>>> System.out.println(config.toString()); >>>> >>>> //cluster.submitTopology("kafka-storm-Phoenix", config, >>>> //builder.createTopology()); >>>> StormSubmitter.submitTopology("kafka-storm-Phoenix-ClusterD", config, >>>> builder.createTopology()); >>>> >>>> >>>> worker logs are saying " Netty reconnect for hostname:6703" is issued >>>> again and again. >>>> >>>> >>>> Thanks, >>>> Siddharth >>>> >>>> >>>> >>> >> >
