enable autoflush in redis cluster client

Signed-off-by: pyalex <moskalenko.alexey@gmail.com>
feast-dev · Dec 17, 2021 · b3edfcf · b3edfcf
1 parent 23b67dd
commit b3edfcf
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/.../connectors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClient.java b/.../connectors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClient.java
@@ -46,9 +46,6 @@ public void flushCommands() {
 
   private RedisClient(StatefulRedisConnection<byte[], byte[]> connection) {
     this.asyncCommands = connection.async();
-
-    // Disable auto-flushing
-    // this.asyncCommands.setAutoFlushCommands(false);
   }
 
   public static RedisClientAdapter create(RedisStoreConfig config) {

diff --git a/...tors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClusterClient.java b/...tors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClusterClient.java
@@ -63,9 +63,6 @@ private RedisClusterClient(Builder builder) {
 
     // allows reading from replicas
     this.asyncCommands.readOnly();
-
-    // Disable auto-flushing
-    this.asyncCommands.setAutoFlushCommands(false);
   }
 
   public static RedisClientAdapter create(RedisClusterStoreConfig config) {