You are going to need to look at the logs for your topology and the logs for the drpc server to see if there is anything in there that indicates what is happening.
- Bobby On Wednesday, June 28, 2017, 11:21:14 PM CDT, sam mohel <[email protected]> wrote: I submitted topology in local without any problem , but in production mode i couldn't as you can see in ui zeros values in columns except execute columns .i got after sometimes in terminal drpcexecutionexception(msg:request timed out)my configurations are Machine A and Machine B storm.yaml in Machine A is storm.zookeeper.servers: - "192.168.x.x" nimbus.host : "192.168.x.x" supervisor.childopts: "-Xmx4g" worker.childopts: "-Xmx4g" storm.yaml in Machine B is storm.zookeeper.servers: - "192.168.x.x" nimbus.host : "192.168.x.x" supervisor.childopts: "-Xmx4g" worker.childopts: "-Xmx4g" i set drpc in the code Config conf = new Config(); List<String> dprcServers = new ArrayList<String>(); dprcServers.add("192.168.x.x") ; conf.put(Config.DRPC_SERVERS, dprcServers); conf.put(Config.DRPC_PORT, 3772);// distributed mode Config conf = createTopologyConfiguration( prop, true); LocalDRPC drpc = null; StormSubmitter.submitTopology( args[0], conf, buildTopology(drpc)); client=new DRPCClient("192.168.x.x", 3772); i used same ip address for storm.zookeeper.servers , nimbus.host ,dprcServers and DRPCClient . Is that wrong ? and i ran nimbus , drpc,ui in Machine A , I ran supervisor in Machine Bi appreciate any help , Thanks
