[Storm][DRPC] Request failed

2019-09-05 03:52发布

We work with storm and use the DRPC to execute some algorithms on the cluster.

When the duration time on each node is less than 60 seconds, there is no trouble: client receives correct result. However when we have to solve bigger problem with the same algorithm (then duration time is more than 60 seconds) we have the following message:

Exception in thread "main" DRPCExecutionException(msg:Request failed) at
backtype.storm.generated.DistributedRPC$execute_result$execute_resultStandardScheme.read(DistributedRPC.java:1222) at 
backtype.storm.generated.DistributedRPC$execute_result$execute_resultStandardScheme.read(DistributedRPC.java:1200) at backtype.storm.generated...

It seems to be about the node, which sends a message to cluster with "Request failed" and doesn't finish algorithm. Hope somebody have a hint to solve this :(

Note that the Client-DRPC-Topology and the 10 test nodes work properly when the duration is less than the minute.

Thank you.

0条回答
登录 后发表回答