Flume事务机制

一、Flume的事务机制 Flume的事务机制类似数据库的事务机制:要么都成功,要么都失败 Flume使用两个独立的事务分别负责从soucrce到channel,以及从channel到sink的事件传递。 1.1 Put 事务流程 doPut:将批数据先写入临时缓冲区 putList doCommit:检查 channel 内存队列是否足够合并 doRollback:channel 内存队列空间不
相关文章
相关标签/搜索