《大数据: Flume 事务》-CSDN博客

网站介绍:一、Flume 事务1. 概念put事务:put事务指source将event放入channel的过程中,开启的事务 流程:source将封装好的event,先放入到putList(事务开启的缓冲区),一批event在放入putList期间,如果发生了异常,就回滚(rollback())事务,此时清空putList,如果没有发生异常,那么就提交(ommit())事务,提交事务将event放入到channel中,这批event就可以写入到channel,写入完成后,清空putList,开始下