From df5040b0a4ef2ae508d05361a277a26eb1817398 Mon Sep 17 00:00:00 2001
From: Thomas Groh <tgroh@google.com>
Date: Fri, 22 Apr 2016 16:41:46 -0700
Subject: [PATCH] Relax assertion in BoundedReadFromUnboundedSourceTest

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

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 094d59702325..73648185c7d0 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
@@ -84,7 +84,7 @@ public Void apply(Iterable<KV<Integer, Integer>> input) {
         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.