Updated Branches: refs/heads/flume-1.5 2b0233906 -> 973f30463
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/973f3046 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/973f3046 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/973f3046 Branch: refs/heads/flume-1.5 Commit: 973f304634f3f3e0604468eaa84d5d445755cffd Parents: 2b02339 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:15:14 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/973f3046/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
