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
