If in my customized sink, I create some threads and schedule it to do some queueing. For example, I would like to drop the events off every 10 seconds. If I start the thread or an executor in the process method of the customized sink class, would have have some negative impact to the threading model in Flume ?
If you create a large number of threads in a sink - that could affect the performance of the agent - simply because there are too many threads. Also, transactions are thread-local - so make sure each transaction is completely owned and run by the same thread. On Sun, Aug 24, 2014 at 7:28 PM, terreyshih <[EMAIL PROTECTED]> wrote: