Flume 事务理解 数据丢失?

put事务 take事务 put事务步骤: doput :先将批数据写入临时缓冲区putlist里面 docommit:去检查channel里面有没有空位置,如果有就传入数据,如果没有那么dorollback就把数据回滚到putlist里面。 take事务步骤: dotake:将数据读取到临时缓冲区takelist,并将数据传到hdfs上。 docommit :去判断数据发送是否成功,若成功那么清
相关文章
相关标签/搜索