[STORM-3006] Distributed RPC documentation needs an update

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.1
• Fix Version/s: 2.0.0, 1.2.2
• Component/s: documentation
• Labels: pull-request-available
• Assignee: Lukasz Gebel
• Reporter: Lukasz Gebel
• Created: 24/Mar/18 19:06
• Updated: 30/Mar/18 19:17
• Resolved: 30/Mar/18 19:17

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"

 

Issue Links

• links to: GitHub Pull Request #2604