Remove transaction from ingestion redis (#480)

(cherry picked from commit c3591ed)
feast-dev · Feb 26, 2020 · ef0821a · ef0821a
1 parent 2d38c4e
commit ef0821a
Showing 1 changed file with 0 additions and 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
@@ -238,15 +238,13 @@ private void executeBatch() throws Exception {
             new Retriable() {
               @Override
               public void execute() {
-                pipeline.multi();
                 mutations.forEach(
                     mutation -> {
                       writeRecord(mutation);
                       if (mutation.getExpiryMillis() != null && mutation.getExpiryMillis() > 0) {
                         pipeline.pexpire(mutation.getKey(), mutation.getExpiryMillis());
                       }
                     });
-                pipeline.exec();
                 pipeline.sync();
                 mutations.clear();
               }