Flume - 如果客户端批量大小大于通道事务容量会发生什么？

Question

我正在阅读Batch Size, Channel Capacity Channel Transaction Capacity. 我有点困惑，假设客户的 Batch Size 是 200，但 Channel 的 Transaction Capacity 是 100。会发生什么：

• 客户端是否将其批量大小降级以匹配通道的容量？
• 客户端是否在 2 个事务中将事件放入通道？
• 客户端是否会尝试将 200 个事件放入一个事务中并收到异常？

我以为有人可能已经知道了，如果我没有收到回复，我会做一个实验 ;-)

这是否意味着在添加新客户端时必须更新这些设置？

Answer 1

至少对于FileChannel 和HDFSEventSink，FileChannel.ChannelCapacity 必须大于HDFSEventSink.batchSize，否则你会得到exception。