We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7586da6 commit c3591edCopy full SHA for c3591ed
ingestion/src/main/java/feast/store/serving/redis/RedisCustomIO.java
@@ -238,15 +238,13 @@ private void executeBatch() throws Exception {
238
new Retriable() {
239
@Override
240
public void execute() {
241
- pipeline.multi();
242
mutations.forEach(
243
mutation -> {
244
writeRecord(mutation);
245
if (mutation.getExpiryMillis() != null && mutation.getExpiryMillis() > 0) {
246
pipeline.pexpire(mutation.getKey(), mutation.getExpiryMillis());
247
}
248
});
249
- pipeline.exec();
250
pipeline.sync();
251
mutations.clear();
252
0 commit comments