You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by sam mohel <sa...@gmail.com> on 2016/01/01 00:50:04 UTC

DRPC didn't get data

i've topology using DRPC when i ran the command of drpc in terminal i got
at hthe end of the log file of drpc
[INFO]Starting Distributed RPC servers...
!!

the code

private static Config createTopologyConfiguration(Properties prop, boolean
localMode) {
 Config conf = new Config();
 List<String> dprcServers = new ArrayList<String>();
dprcServers.add("localhost"); conf.put(Config.DRPC_SERVERS, dprcServers);
conf.put(Config.DRPC_PORT, 3772);
if (!localMode)
conf.put(Config.STORM_CLUSTER_MODE, new String("distributed"));

in the main class
Config conf = createTopologyConfiguration(prop, true); LocalDRPC drpc = new
LocalDRPC(); LocalCluster cluster = new LocalCluster(); cluster.
submitTopology(TOPOLOGY_NAME, conf, buildTopology(drpc));


i'll appercaite any help