Trident Word Counting topology question

[ilya Kholinow <i....@pixonic.ru>]

Hi!
I'm trying to play with Trident + WordCountTopology:
https://github.com/nathanmarz/storm-starter/blob/master/src/jvm/storm/starter/trident/TridentWordCount.java
(The
only change to that file is " conf.put(Config.DRPC_SERVERS,
Collections.singletonList("10.10.10.1")); " when subbmiting to Cluster)

When i use LocalCluster and LocalDrpc - everything is ok.
When i upload to Strom cluster (3 nodes) and use DRPCClient like this:

DRPCClient client = new DRPCClient("10.10.10.1", 3772);
try {
    System.out.println("DRPC RESULT: " + client.execute("words", "cat
the dog jumped"));
} catch (TException | DRPCExecutionException e) {
    e.printStackTrace();
}

I get:

org.apache.thrift7.TApplicationException: execute failed: unknown result
at
backtype.storm.generated.DistributedRPC$Client.recv_execute(DistributedRPC.java:99)
at
backtype.storm.generated.DistributedRPC$Client.execute(DistributedRPC.java:78)
at backtype.storm.utils.DRPCClient.execute(DRPCClient.java:71)
at Program.remoteWordCount(Program.java:29)
at Program.access$000(Program.java:13)
at Program$1.run(Program.java:20)

but when i set conf.setNumWorkers(1) everything works fine. (I use 0.9.1
version)

What am i'm doing wrong?