beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] incubator-beam git commit: Relax assertion in BoundedReadFromUnboundedSourceTest
Date Sat, 23 Apr 2016 00:11:52 GMT
Relax assertion in BoundedReadFromUnboundedSourceTest

Deflakes the test


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fecd0362
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fecd0362
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fecd0362

Branch: refs/heads/master
Commit: fecd0362f5c1710c7fee0b2a03cc8549d1b8f75a
Parents: a05bd74
Author: Thomas Groh <tgroh@google.com>
Authored: Fri Apr 22 16:41:46 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Fri Apr 22 17:11:33 2016 -0700

----------------------------------------------------------------------
 .../org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fecd0362/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java
b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java
index 119440a..30f3eca 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSourceTest.java
@@ -100,7 +100,7 @@ public class BoundedReadFromUnboundedSourceTest implements Serializable{
         values.add(kv.getValue());
       }
       if (timeBound) {
-        assertTrue(values.size() > 2);
+        assertTrue(values.size() >= 1);
       } else if (dedup) {
         // Verify that at least some data came through.  The chance of 90% of the input
         // being duplicates is essentially zero.


Mime
View raw message