You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/03/30 19:16:19 UTC
[1/2] storm git commit: Updated Distributed-RPC.md with new way of
DRPCClient initialization and added storm.thrift.transport property settings
example.
Repository: storm
Updated Branches:
refs/heads/1.x-branch bde95c311 -> a03917b03
Updated Distributed-RPC.md with new way of DRPCClient initialization and added storm.thrift.transport property settings example.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/65720ac7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/65720ac7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/65720ac7
Branch: refs/heads/1.x-branch
Commit: 65720ac71ad85966cd59306c47c5ac5ab988d34f
Parents: 059f7db
Author: Lukasz Gebel <lu...@gmail.com>
Authored: Sat Mar 24 20:30:23 2018 +0100
Committer: Lukasz Gebel <lu...@gmail.com>
Committed: Sat Mar 24 20:30:23 2018 +0100
----------------------------------------------------------------------
docs/Distributed-RPC.md | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/65720ac7/docs/Distributed-RPC.md
----------------------------------------------------------------------
diff --git a/docs/Distributed-RPC.md b/docs/Distributed-RPC.md
index b20419a..a0703a7 100644
--- a/docs/Distributed-RPC.md
+++ b/docs/Distributed-RPC.md
@@ -12,7 +12,12 @@ DRPC is not so much a feature of Storm as it is a pattern expressed from Storm's
Distributed RPC is coordinated by a "DRPC server" (Storm comes packaged with an implementation of this). The DRPC server coordinates receiving an RPC request, sending the request to the Storm topology, receiving the results from the Storm topology, and sending the results back to the waiting client. From a client's perspective, a distributed RPC call looks just like a regular RPC call. For example, here's how a client would compute the results for the "reach" function with the argument "http://twitter.com":
```java
-DRPCClient client = new DRPCClient("drpc-host", 3772);
+Config conf = new Config();
+ 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);
+DRPCClient client = new DRPCClient(conf, "drpc-host", 3772);
String result = client.execute("reach", "http://twitter.com");
```
@@ -89,12 +94,14 @@ Launching a DRPC server can be done with the `storm` script and is just like lau
bin/storm drpc
```
-Next, you need to configure your Storm cluster to know the locations of the DRPC server(s). This is how `DRPCSpout` knows from where to read function invocations. This can be done through the `storm.yaml` file or the topology configurations. Configuring this through the `storm.yaml` looks something like this:
+Next, you need to configure your Storm cluster to know the locations of the DRPC server(s). This is how `DRPCSpout` knows from where to read function invocations. This can be done through the `storm.yaml` file or the topology configurations. You should also specify storm.thrift.transport property to match DRPCClient settings. Configuring this through the `storm.yaml` looks something like this:
```yaml
drpc.servers:
- "drpc1.foo.com"
- "drpc2.foo.com"
+
+storm.thrift.transport: "org.apache.storm.security.auth.plain.PlainSaslTransportPlugin"
```
Finally, you launch DRPC topologies using `StormSubmitter` just like you launch any other topology. To run the above example in remote mode, you do something like this:
[2/2] storm git commit: Merge branch '1.x-branch' of
https://github.com/rauluka/storm into STORM-3006
Posted by bo...@apache.org.
Merge branch '1.x-branch' of https://github.com/rauluka/storm into STORM-3006
STORM-3006: updated-DRPC-docs
This closes #2604
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a03917b0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a03917b0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a03917b0
Branch: refs/heads/1.x-branch
Commit: a03917b0376c7a8518451822a14bc9bd01a92068
Parents: bde95c3 65720ac
Author: Robert Evans <ev...@yahoo-inc.com>
Authored: Fri Mar 30 12:08:19 2018 -0500
Committer: Robert Evans <ev...@yahoo-inc.com>
Committed: Fri Mar 30 12:08:19 2018 -0500
----------------------------------------------------------------------
docs/Distributed-RPC.md | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------