Updated Branches: refs/heads/trunk 7951c4e9b -> 492cd8d08
FLUME-2304. DatasetSink test fails unexpectedly. (Ryan Blue 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/492cd8d0 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/492cd8d0 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/492cd8d0 Branch: refs/heads/trunk Commit: 492cd8d08cab347e02e43805b47435413d16937c Parents: 7951c4e Author: Hari Shreedharan <hshreedha...@apache.org> Authored: Mon Jan 20 14:15:14 2014 -0800 Committer: Hari Shreedharan <hshreedha...@apache.org> Committed: Mon Jan 20 14:16:57 2014 -0800 ---------------------------------------------------------------------- .../src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/492cd8d0/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java b/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java index 5708f0c..bd0e1dc 100644 --- a/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java +++ b/flume-ng-sinks/flume-dataset-sink/src/test/java/org/apache/flume/sink/kite/TestDatasetSink.java @@ -270,7 +270,6 @@ public class TestDatasetSink { sink.start(); sink.process(); - Assert.assertEquals(Sets.<GenericData.Record>newHashSet(), read(records)); Assert.assertEquals("Should have committed", 0, remaining(in)); Thread.sleep(1100); // sleep longer than the roll interval
