[jira] [Created] (STORM-836) DPRC request failed after DRPC server restarted

["Yohn Wei (JIRA)" <ji...@apache.org>]

Yohn Wei created STORM-836:
------------------------------

             Summary: DPRC request failed after DRPC server restarted
                 Key: STORM-836
                 URL: https://issues.apache.org/jira/browse/STORM-836
             Project: Apache Storm
          Issue Type: Bug
    Affects Versions: 0.9.3
            Reporter: Yohn Wei
            Assignee: Yohn Wei


When the DRPC server was killed and then restarted, the DRPC client would throw a DRPCExecutionException (msg:Request failed) for a while, off and on.

Here is my client code:
{code:java}
DRPCClient client = new DRPCClient("hd181", 3772);

for (int i = 0; i < 100; ++i) {
	System.out.println(client.execute("drpcFunc", "aaa"));
}
{code}

and the error messages:
{code}
Exclamation-6:aaa!!!
Exception in thread "main" DRPCExecutionException(msg:Request failed)
	at backtype.storm.generated.DistributedRPC$execute_result.read(DistributedRPC.java:904)
	at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:78)
	at backtype.storm.generated.DistributedRPC$Client.recv_execute(DistributedRPC.java:92)
	at backtype.storm.generated.DistributedRPC$Client.execute(DistributedRPC.java:78)
	at backtype.storm.utils.DRPCClient.execute(DRPCClient.java:71)
	at com.enjoyor.storm.kafka.example.DRPCTest.main(DRPCTest.java:18)
{code}

As you can see, the client can get few valid results at beginning and then get a failed request.

This problem would last about 10 minutes after restarting the server, and then the server would be back to normal.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)