2.3 Flume事务剖析

你的账户-520

bug

她的账户+520

Put事务流程：

1. doPut:将批数据先写入临时缓冲区putList
2. doCommit:检查channel内存队列是否足够合并
3. doRollback:channel内存队列空间不足，回滚数据，直接将数据丢弃。

Take事务流程：

1. doTake:将数据取到临时缓冲区takeList，并将数据发送到目标位置（比如：HDFS、Hive等）
2. doCommit:如果数据全部发送成功，则清除临时缓冲区takeList
3. doRollback:数据发送过程中如果出现异常，rollback将临时缓冲区takeList中的数据归还给channel内存队列。

实时反馈

1. 关于Flume的Put事务流程的描述，错误的是：

A 临时缓冲区putList的容量可以大于channel内存队列的容量。

B doPut将批数据先写入临时缓冲区putList。

C doCommit检查channel内存队列是否足够合并。

D doRollback:channel内存队列空间不足，回滚数据，直接将数据丢弃。

2. 关于Flume的Take事务流程的描述，错误的是：

A doTake:将数据取到临时缓冲区takeList，并将数据发送到目标位置（比如：HDFS、Hive等）。

B doCommit:如果数据全部发送成功，则清除临时缓冲区takeList。

C doRollback:数据发送过程中如果出现异常，rollback将临时缓冲区takeList中的数据归还给channel内存队列。

D Flume通过Sink输出的数据不存在重复处理的情况。

答案：

1.A 2.D