You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "Lukasz Gebel (JIRA)" <ji...@apache.org> on 2018/03/24 19:07:00 UTC
[jira] [Created] (STORM-3006) Distributed RPC documentation needs
an update
Lukasz Gebel created STORM-3006:
-----------------------------------
Summary: Distributed RPC documentation needs an update
Key: STORM-3006
URL: https://issues.apache.org/jira/browse/STORM-3006
Project: Apache Storm
Issue Type: Improvement
Components: documentation
Affects Versions: 1.2.1
Reporter: Lukasz Gebel
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"*
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)