flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esam...@apache.org
Subject svn commit: r1160463 - /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
Date Mon, 22 Aug 2011 22:03:49 GMT
Author: esammer
Date: Mon Aug 22 22:03:49 2011
New Revision: 1160463

URL: http://svn.apache.org/viewvc?rev=1160463&view=rev
Log:
- Force a flush upon rolling a file in the RollingFileSink (generally not necessary, but makes
  sense to be explicit when talking about durability).

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java?rev=1160463&r1=1160462&r2=1160463&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
(original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
Mon Aug 22 22:03:49 2011
@@ -89,6 +89,7 @@ public class RollingFileSink extends Abs
         logger.debug("Closing file {}", pathController.getCurrentFile());
 
         try {
+          outputStream.flush();
           outputStream.close();
           shouldRotate = false;
         } catch (IOException e) {



Mime
View raw message