DRPC localhost

[kalliopi kalantzaki <ts...@yahoo.gr.INVALID>]

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.

|  

 |