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)