特牛网址导航

flume —— 事务_flume中source有do rollback操作吗-CSDN博客

网友收藏
事务:从开始到结束为原子性,开始到结束整条链路成功才提交flume使用两个独立的事务分别负责从soucrce到channel,以及从channel到sink的事件传递。1、soucrce到channeldoPut: 把批数据写入到临时缓冲区putListdoCommit: 检查Channel容量是否足够,如果容量足够则把putList里的数据发送到Channel,然后清空putList中的数据。doRollBack:如果Channel容量不够,则把数据回滚到putList注:Flume_flume中source有do rollback操作吗