Re: Testing serializers with multiple workers

2016-11-18 Thread Chien Le
Ohad, We found that we had to use localOrShuffle grouping in order to see activity in the same worker as the spout. -Chien From: Ohad Edelstein Sent: Friday, November 18, 2016 8:38:35 AM To: user@storm.apache.org Subject: Re: Testing

RE: Bolt slow down the emit speed of spout

2016-10-19 Thread Chien Le
lelism of kafkaspout? 发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 发件人: Jungtaek Lim<mailto:kabh...@gmail.com> 发送时间: 2016年10月19日 9:48 收件人: Chen Junfeng<mailto:k-2f...@hotmail.com>; Chien Le<mailto:chien...@ds-iq.com>; user@storm.apache.org<mailto:user@st

RE: Bolt slow down the emit speed of spout

2016-10-18 Thread Chien Le
dstat -d is measuring your disk throughput, yes? Did you mean dstat -n? Otherwise, dstat -d showing 300MB/s doesn't eliminate disk as your bottleneck. I would try using iostat -x 1 and see what your %util and svc times are to truly eliminate disk as the bottleneck. -Chien From: Chen Junfeng