Hi All
there are two drpc servers on my storm clusters.
my question is if one server is down,how can switch to another server
automatically.
the drcpclient class can be assigned one Server IP at a time.
I found one solution at https://github.com/mykidong/storm-finagle-drpc-client
Is there ano
Hi All
I am running a drpc topology for data filtering. I can get the result when i
run DrpcClient execute method.
However ,when i check the drpc.log on drpc server. I find some exceptions below:
o.a.t.s.TNonblockingServer [WARN] Got an IOException during write!
java.io.IOException: Connectio
ts to 64.
Maybe try increasing this?
--
Derek
On 7/10/14, 21:29, /pig五餐肉 wrote:
> Hi All
>
>
> I am using to storm drpc topology to do data sorting and filterting.
> the input stream is the data string sequence.
> everything is fine when i use drpcclient class to send string to out
rmance
This could help:
https://github.com/mykidong/storm-finagle-drpc-client
2014-07-11 11:29 GMT+09:00 /pig五餐肉 <76006...@qq.com>:
Hi All
I am using to storm drpc topology to do data sorting and filterting.
the input stream is the data string sequence.
everything is fine when i us
Hi All
I am using to storm drpc topology to do data sorting and filterting.
the input stream is the data string sequence.
everything is fine when i use drpcclient class to send string to out drpc
server in a single thread.the latency is about 65ms.
but when i send data in mutiple threads (about
