Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.2.1
Description
Currently in: http://storm.apache.org/releases/1.2.1/Distributed-RPC.html
examples of DRPCClient initialization are outdated as you need to provide config parameter:
Config conf = new Config();
conf.setDebug(false);
conf.put("storm.thrift.transport", "org.apache.storm.security.auth.plain.PlainSaslTransportPlugin");
conf.put(Config.STORM_NIMBUS_RETRY_TIMES, 3);
conf.put(Config.STORM_NIMBUS_RETRY_INTERVAL, 10);
conf.put(Config.STORM_NIMBUS_RETRY_INTERVAL_CEILING, 20);
this.drpcClient = new DRPCClient(conf, "10.0.9.10", 3772);
What it more it would be useful to state that org.apache.storm.security.auth.plain.PlainSaslTransportPlugin can be used in DRPC as SimpleTransportPlugin is deprecated.
So also storm.yaml example can be extended:
drpc.servers:
- "drpc1.foo.com"
- "drpc2.foo.com"
storm.thrift.transport: "org.apache.storm.security.auth.plain.PlainSaslTransportPlugin"
Attachments
Issue Links
- links to