svn commit: r1160465 - /incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java

[es...@apache.org]

Author: esammer
Date: Mon Aug 22 22:03:56 2011
New Revision: 1160465

URL: http://svn.apache.org/viewvc?rev=1160465&view=rev
Log:
- Output the last line of each file when testing the RollingFileSink.

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

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java?rev=1160465&r1=1160464&r2=1160465&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestRollingFileSink.java Mon Aug 22 22:03:56 2011
@@ -1,6 +1,9 @@
 package org.apache.flume.sink;
 
+import java.io.BufferedReader;
 import java.io.File;
+import java.io.FileReader;
+import java.io.IOException;
 
 import org.apache.flume.Context;
 import org.apache.flume.Event;
@@ -48,7 +51,7 @@ public class TestRollingFileSink {
 
   @Test
   public void testAppend() throws InterruptedException, LifecycleException,
-      EventDeliveryException {
+      EventDeliveryException, IOException {
 
     Context context = new Context();
 
@@ -68,7 +71,19 @@ public class TestRollingFileSink {
     sink.close(context);
 
     for (String file : sink.getDirectory().list()) {
-      logger.debug("Produced file:{}", file);
+      BufferedReader reader = new BufferedReader(new FileReader(new File(
+          sink.getDirectory(), file)));
+
+      String lastLine = null;
+      String currentLine = null;
+
+      while ((currentLine = reader.readLine()) != null) {
+        lastLine = currentLine;
+      }
+
+      logger.debug("Produced file:{} lastLine:{}", file, lastLine);
+
+      reader.close();
     }
   }
 }