[FLUME-1011] AvroSource should have a configurable max thread count

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.2.0
• Assignee: Juhani Connolly
• Reporter: Mike Percy
• Created: 01/Mar/12 02:27
• Updated: 10/Apr/12 01:14
• Resolved: 10/Apr/12 00:48

Description

AvroSource via NettyServer uses Executors.newCachedThreadPool() when accepting incoming connections, which means that there is no upper limit on the number of threads that can be spawned. It would be good to expose configurable core & max thread pool sizes and provide some sane defaults to avoid OutOfMemory errors.