hi ,
I am using 0.9.3 release of storm. Thanks, Siddharth Ubale On Wed, Jan 21, 2015 at 1:47 PM, Anis Nasir <[email protected]> wrote: > 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 >>>>> >>>>> >>>>> >>>> >>> >> >
