From 40dde510a2db60d82995d990a0dcb09db2dcfdfb Mon Sep 17 00:00:00 2001 From: xuchuan Date: Mon, 29 Aug 2022 17:39:59 +0800 Subject: [PATCH] fix(datastore): keep retrying to write WAL even if terminated (#1052) --- .../src/main/java/ai/starwhale/mlops/datastore/WalManager.java | 1 - 1 file changed, 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 index 8d9e365a59..07c0681ae3 100644 --- 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)))