Updated Branches: refs/heads/flume-1.3.0 c47e7a91d -> d25e7cd85
FLUME-1684. Re-enable empty file unit test (Mike Percy via Hari Shreedharan) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/d25e7cd8 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/d25e7cd8 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/d25e7cd8 Branch: refs/heads/flume-1.3.0 Commit: d25e7cd856f2cf36f60175de74f5ba50bf035944 Parents: c47e7a9 Author: Hari Shreedharan <[email protected]> Authored: Fri Nov 9 11:15:53 2012 -0800 Committer: Hari Shreedharan <[email protected]> Committed: Fri Nov 9 11:16:37 2012 -0800 ---------------------------------------------------------------------- .../client/avro/TestSpoolingFileLineReader.java | 5 +---- 1 files changed, 1 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/d25e7cd8/flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java b/flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java index 8463176..740bc98 100644 --- a/flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java +++ b/flume-ng-core/src/test/java/org/apache/flume/client/avro/TestSpoolingFileLineReader.java @@ -33,7 +33,6 @@ import org.apache.flume.FlumeException; import org.junit.After; import org.junit.Assert; import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; import com.google.common.base.Charsets; @@ -363,10 +362,8 @@ public class TestSpoolingFileLineReader { /** - * Empty files should be skipped over when reading directory. - * This feature is not currently implemented. + * Empty files should be treated the same as other files and rolled. */ - @Ignore @Test public void testBehaviorWithEmptyFile() throws IOException { File f1 = new File(tmpDir.getAbsolutePath() + "/file1");
