[beam] branch master updated: BEAM-6494 When we have prepared a transaction to be executed on the Redis server, we now push that transaction to the server. Previously the buffer was only flushed when the pipeline was closed.

[ie...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 9c0dd47  BEAM-6494 When we have prepared a transaction to be executed on the Redis server, we now push that transaction to the server. Previously the buffer was only flushed when the pipeline was closed.
     new 445ac6c  Merge pull request #7645: [BEAM-6494] Fixes bug in RedisIO
9c0dd47 is described below

commit 9c0dd475cc867b59b527229f2e5a8d6a2f7c47f2
Author: Rob <Ro...@fluidly.com>
AuthorDate: Mon Jan 28 13:28:10 2019 +0000

    BEAM-6494 When we have prepared a transaction to be executed on the Redis server, we now push that transaction to the server. Previously the buffer was only flushed when the pipeline was closed.
---
 .../io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java b/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
index 8d6b0be..bdb0d1c 100644
--- a/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
+++ b/sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java
@@ -555,6 +555,7 @@ public class RedisIO {
 
         if (batchCount >= DEFAULT_BATCH_SIZE) {
           pipeline.exec();
+          pipeline.sync();
           pipeline.multi();
           batchCount = 0;
         }
@@ -627,6 +628,7 @@ public class RedisIO {
       public void finishBundle() {
         if (pipeline.isInMulti()) {
           pipeline.exec();
+          pipeline.sync();
         }
         batchCount = 0;
       }