flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject git commit: FLUME-2304. DatasetSink test fails unexpectedly.
Date Mon, 20 Jan 2014 22:17:06 GMT
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 <hshreedharan@apache.org>
Authored: Mon Jan 20 14:15:14 2014 -0800
Committer: Hari Shreedharan <hshreedharan@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


Mime
View raw message