FLUME-681: high msg rate syslogTcpThreadSource threads can lead to OOM

- Put limit on queue.
cloudera · Jul 1, 2011 · c266dd8 · c266dd8
1 parent bef14eb
commit c266dd8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java b/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java
@@ -58,7 +58,7 @@ public class SyslogTcpSourceThreads extends EventSource.Base {
 
   final public static int SYSLOG_TCP_PORT = 514;
   final int port;
-  final LinkedBlockingQueue<Event> eventsQ = new LinkedBlockingQueue<Event>();
+  final LinkedBlockingQueue<Event> eventsQ = new LinkedBlockingQueue<Event>(100000);
   final List<ReaderThread> readers = Collections
       .synchronizedList(new ArrayList<ReaderThread>());
   final AtomicLong rejects = new AtomicLong();