flume执行流程

flume执行流程： source执行channel的doput方法，将接受到的event先放入putlist里面临时缓存起来，当到达必定的量（batchSize）的时候，执行docommit方法， 将putlist中的event放入channel的queue（queue的大小是capacity）中，当sink执行时，会调用channel的dotake方法，将取出的event放入到takelist

>>阅读原文<<