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 B
i appreciate any help , Thanks
