storm 锚定tuple后 发现最后的tuple处理完成后没有ack spout 而是直接timeout调用fail

垂垂 发布于 2015/07/13 15:02
阅读 335
收藏 0
Spout:
List<Student> list = studentService.getStudent(beginId, limit); 
for (Student student : list) {
    String messageId = student.getName() + "-" + student.getSubject() + "-" + student.getSchool(); 
collector.emit(new Values(student.getName(), student.getSubject(), student.getSchool()), messageId);

}

Bolt1:


studentService.addSubject(name, subject, school, score); 
outputCollector.emit(tuple, new Values(name, school));//锚定tuple 
outputCollector.ack(tuple);

Bolt2:


studentService.addSchool(name, school, score);
加载中
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部