You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by rg...@apache.org on 2013/04/02 01:29:54 UTC

svn commit: r1463333 - /logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java

Author: rgoers
Date: Mon Apr  1 23:29:54 2013
New Revision: 1463333

URL: http://svn.apache.org/r1463333
Log:
Only include up to batchSize events in a batch

Modified:
    logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java

Modified: logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java
URL: http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java?rev=1463333&r1=1463332&r2=1463333&view=diff
==============================================================================
--- logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java (original)
+++ logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java Mon Apr  1 23:29:54 2013
@@ -343,7 +343,7 @@ public class FlumePersistentManager exte
                                 status = cursor.getFirst(key, data, LockMode.RMW);
                                 if (batchSize > 1) {
                                     BatchEvent batch = new BatchEvent();
-                                    while (status == OperationStatus.SUCCESS) {
+                                    for (int i = 0; status == OperationStatus.SUCCESS && i < batchSize; ++i) {
                                         SimpleEvent event = createEvent(data);
                                         if (event != null) {
                                             batch.addEvent(event);