Hi，all：
When I use storm dprc, some problems are happened. I use a topology
to calculate some indicators and drpc-client get the result of topology
scheduled.
At first, it runs very well, but a few days later, sometimes the drpc-client
can successfully get the result of topology, but sometimes it receives an
exception(DRPCExecutionException). In this case, there’s no exception or
timeout occurred in the topology.
When I restart the topology, the drpc-client can successfully get the result
of topology again. But the problem will occurs after a few days again.
Exception information is as follows:
com.jd.bdp.thimphu.drpc.client.exception.DRPCException: Failed to get
statistics result set for status code [817].
at
com.jd.bdp.thimphu.drpc.client.orders.OrderStatusStatisticsClient.getOrderSt
atisticsResultSetByStatusCode(OrderStatusStatisticsClient.java:79)
at
com.jd.bdp.thimphu.drpc.client.orders.OrderStatusStatisticsMain$OrderStatusS
tatisticsTask.run(OrderStatusStatisticsMain.java:95)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.
java:317)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$
101(ScheduledThreadPoolExecutor.java:98)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeri
odic(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Sch
eduledThreadPoolExecutor.java:204)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.ja
va:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:9
08)
at java.lang.Thread.run(Thread.java:662)
Caused by: DRPCExecutionException(msg:Request failed)
at
backtype.storm.generated.DistributedRPC$execute_result.read(DistributedRPC.j
ava:887)
at
org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:78)
at
backtype.storm.generated.DistributedRPC$Client.recv_execute(DistributedRPC.j
ava:75)
at
backtype.storm.generated.DistributedRPC$Client.execute(DistributedRPC.java:6
1)
at backtype.storm.utils.DRPCClient.execute(DRPCClient.java:54)
at
com.jd.bdp.thimphu.drpc.client.orders.OrderStatusStatisticsClient.getOrderSt
atisticsResultSetByStatusCode(OrderStatusStatisticsClient.java:75)
... 10 more
Thanks!
朱春来【大数据平台部 �C 基础服务组】
=====================================
电话：010-57656312
地址：北京市朝阳区北辰西路8号北辰世纪中心16楼
邮编：100101
=====================================
网购上京东，省钱又放心！
