fix(datastore): keep retrying to write WAL even if terminated (#1052)

star-whale · Aug 29, 2022 · 40dde51 · 40dde51
1 parent 035b88d
commit 40dde51
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/server/controller/src/main/java/ai/starwhale/mlops/datastore/WalManager.java b/server/controller/src/main/java/ai/starwhale/mlops/datastore/WalManager.java
@@ -325,7 +325,6 @@ private void writeToObjectStore(boolean clearOutput) {
                             Retry.of("put", RetryConfig.custom()
                                     .maxAttempts(10000)
                                     .intervalFunction(IntervalFunction.ofExponentialRandomBackoff(100, 2.0, 0.5, 10000))
-                                    .retryOnException(e -> !terminated)
                                     .build()),
                             () -> this.objectStore.put(this.logFilePrefix + this.logFileIndex,
                                     this.compressedBuffer.slice(0, compressedBufferSize)))