Merge pull request apache#6682 from casidiablo/redis-io-fix-finish

[BEAM-5734] RedisIO: only call Jedis.exec() on finishBundle if there is something to send
mikeymezher · Nov 26, 2018 · 658630d · 658630d
2 parents 7eba171 + 8341312
commit 658630d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/io/redis/src/test/java/org/apache/beam/sdk/io/redis/RedisIOTest.java b/sdks/java/io/redis/src/test/java/org/apache/beam/sdk/io/redis/RedisIOTest.java
@@ -86,7 +86,7 @@ public void testBulkRead() throws Exception {
   @Test
   public void testWriteReadUsingDefaultAppendMethod() throws Exception {
     ArrayList<KV<String, String>> data = new ArrayList<>();
-    for (int i = 0; i < 100; i++) {
+    for (int i = 0; i < 8000; i++) {
       KV<String, String> kv = KV.of("key " + i, "value " + i);
       data.add(kv);
     }