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:
thanks On Aug 24, 2014, at 10:20 PM, Hari Shreedharan <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext