I have created a simple topology

-----
TopologyBuilder builder = new TopologyBuilder();

// LocalDRPC drpc = new LocalDRPC();    commented on purpose
// DRPCSpout spout = new DRPCSpout("update_data", drpc);

DRPCSpout spout = new DRPCSpout("update_data");
builder.setSpout("drpc", spout);

// Rest of the code

StormSubmitter.submitTopologyWithProgressBar("topo1", conf,
                    builder.createTopology());
-------


While deploying the topology remotely. how do tell the spout , which drpc
server to connect to ?
I only have storm drpc server running in nimbus host. While checking the
drpc log, I do not see any drpc request , my python storm drpc client is
making.   This works perfectly fine , when run locally.

./Rahul

Reply via email to