The column name is “Emitted”, “Transferred”, etc, which indicates a statistic value. Are you sure the above data is keeping changing while you refresh the web page?
发件人: 张炜 [mailto:[email protected]] 发送时间: 2015年3月16日 11:08 收件人: [email protected] 主题: Re: Why Trident always emit tuples? Please review the screenshot attached. On Mon, Mar 16, 2015 at 11:06 AM 张炜 <[email protected] <mailto:[email protected]> > wrote: Dear all, I found an interesting problem when I use Trident, please kindly help. Even there is no operation in spout.execute() command, Storm UI still shows that lots of tuples being emitted. Please refer to the Screenshot attached. Also the source code is shown below ( the source codes might not be exact the same as in eclipse because of the format problem, it is to show logic): tpy.newStream("bbb", new BaseRichSpout() { @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declare(new Fields("lines")); } @Override public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) { // TODO Auto-generated method stub } @Override public void nextTuple() { // TODO Auto-generated method stub } }).each(new Fields("lines"), new Filter() { @Override public void prepare(Map conf, TridentOperationContext context) { // TODO Auto-generated method stub } @Override public void cleanup() { // TODO Auto-generated method stub } @Override public boolean isKeep(TridentTuple tuple) { System.out.println(tuple); return false; } }); Thank you very much! Regards, Sai
