From bbc16c1e5e840f6acc87c323ca9793192f2adbca Mon Sep 17 00:00:00 2001
From: Julio Anthony Leonard <JulioAnthonyLeonard@gmail.com>
Date: Tue, 25 Feb 2020 12:04:40 +0700
Subject: [PATCH] Remove transaction from ingestion redis (#480)

(cherry picked from commit c3591edc37dbb5afe2a5058ffbf0a2cc03f59775)
---
 .../src/main/java/feast/store/serving/redis/RedisCustomIO.java  | 2 --
 1 file changed, 2 deletions(-)

diff --git a/ingestion/src/main/java/feast/store/serving/redis/RedisCustomIO.java b/ingestion/src/main/java/feast/store/serving/redis/RedisCustomIO.java
index 8c142b66c9..8541baaffc 100644
--- a/ingestion/src/main/java/feast/store/serving/redis/RedisCustomIO.java
+++ b/ingestion/src/main/java/feast/store/serving/redis/RedisCustomIO.java
@@ -238,7 +238,6 @@ private void executeBatch() throws Exception {
             new Retriable() {
               @Override
               public void execute() {
-                pipeline.multi();
                 mutations.forEach(
                     mutation -> {
                       writeRecord(mutation);
@@ -246,7 +245,6 @@ public void execute() {
                         pipeline.pexpire(mutation.getKey(), mutation.getExpiryMillis());
                       }
                     });
-                pipeline.exec();
                 pipeline.sync();
                 mutations.clear();
               }