Permalink
Browse files

FLUME-697: ExecNioSource has an unbounded queue that can cause OOME

  • Loading branch information...
1 parent 1f5c610 commit ec588eb205881c7b1caab3fb0c31a17cd0cc4d75 @jmhsieh jmhsieh committed Jul 2, 2011
Showing with 2 additions and 1 deletion.
  1. +2 −1 flume-core/src/main/java/com/cloudera/flume/handlers/exec/ExecNioSource.java
@@ -66,7 +66,8 @@
private final AtomicBoolean errFinished = new AtomicBoolean(false);
private final AtomicBoolean outFinished = new AtomicBoolean(false);
- private final BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<Event>();
+ private final BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<Event>(
+ 1000);
private static Logger LOG = LoggerFactory.getLogger(ExecNioSource.class);

0 comments on commit ec588eb

Please sign in to comment.