Skip to content

Commit e2349ca

Browse files
author
Lavkesh Lahngir
committed
Future should be cleared everytime sync is called
1 parent 1894b20 commit e2349ca

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

ingestion/src/main/java/feast/store/serving/redis/RedisStandaloneIngestionClient.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,11 @@ public boolean isConnected() {
7878
public void sync() {
7979
// Wait for some time for futures to complete
8080
// TODO: should this be configurable?
81-
LettuceFutures.awaitAll(60, TimeUnit.SECONDS, futures.toArray(new RedisFuture[0]));
82-
futures.clear();
81+
try {
82+
LettuceFutures.awaitAll(60, TimeUnit.SECONDS, futures.toArray(new RedisFuture[0]));
83+
} finally {
84+
futures.clear();
85+
}
8386
}
8487

8588
@Override

0 commit comments

Comments
 (0)