Hello,
I am running the typical example ManualDRPC as seen below in storm 1.1.0:
| TopologyBuilder builder = new TopologyBuilder(); |
|
|
|
|
| DRPCSpout spout = new DRPCSpout("exclamation"); |
|
| builder.setSpout("drpc", spout); |
|
| builder.setBolt("exclaim", new ExclamationBolt(),
3).shuffleGrouping("drpc"); |
|
| builder.setBolt("return", new ReturnResults(),
3).shuffleGrouping("exclaim"); |
|
|
|
|
| Config conf = new Config(); |
|
| StormSubmitter.submitTopology("exclaim", conf, builder.createTopology()); |
|
|
| try (DRPCClient drpc = DRPCClient.getConfiguredClient(conf)) { |
|
| System.out.println(drpc.execute("exclamation", "aaa")); |
|
| System.out.println(drpc.execute("exclamation", "bbb")); |
|
} |
|
I have installed the local cluster and started DRPC server on localhost with
the default settings. Now when i make a internal call like the last two lines o
code i get the result. However, if i make an external call from another program
using the
Config conf = new Config();
conf.setDebug(false);
Map defaultConfig = Utils.readDefaultConfig();
conf.putAll(defaultConfig);
DRPCClient client = new DRPCClient(conf, "127.0.0.1", 3772);String result =
client.execute("exclamation", "aaa");
i get the WARN o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR
2001ms (NOT MAX) and i never take a response. In addition, if i make an hhtp
post like localhost:3774/drpc/exclamation/aaaa i also never get any response.
Does anyone have any ideas about how can i solve this problem?? Is there any
special yalm configuration i don;t know about drpc?
Thank you in advance.
|
|
