I can guess something can you help me ?
I ran my topology in production mode with 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
On Wed, Jun 28, 2017 at 7:11 PM, sam mohel <[email protected]> wrote:
> @Bobby @Navin Thanks for your time . Is there something i should check it
> ?
>
