You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2014/01/20 23:17:06 UTC
git commit: FLUME-2304. DatasetSink test fails unexpectedly.
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 <hs...@apache.org>
Authored: Mon Jan 20 14:15:14 2014 -0800
Committer: Hari Shreedharan <hs...@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