Problems about Strom DRPC.

[朱春来 <zh...@jd.com>]

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

=====================================

�����Ͼ�����ʡǮ�ַ��ģ�