Hi Derek Thanks. I set drpc.worker.threads to 256 and drpc.queue.size to 512 before testing.
------------------ 原始邮件 ------------------ 发件人: "Derek Dagit";<der...@yahoo-inc.com>; 发送时间: 2014年7月11日(星期五) 晚上9:33 收件人: "user"<user@storm.incubator.apache.org>; 主题: Re: Storm Drpc Performance drpc.worker.threads defaults 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 drpc > server in a single thread.the latency is about 65ms. > but when i send data in mutiple threads (about 200 threads) at the same time, > the latency is high. some threads are more than 1000ms. > > > I have also try the offical demo BasicDRPCTestTopology. > the issue is the same. > > > env: 11 machines(7g ram,8 cores) > > > is there a way to address this issue ? >
