diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/util/AbstractWALChannel.java b/s3stream/src/main/java/com/automq/stream/s3/wal/util/AbstractWALChannel.java
index a99c39b2cc..88ff3992e3 100644
--- a/s3stream/src/main/java/com/automq/stream/s3/wal/util/AbstractWALChannel.java
+++ b/s3stream/src/main/java/com/automq/stream/s3/wal/util/AbstractWALChannel.java
@@ -83,7 +83,7 @@ public int retryRead(ByteBuf dst, long position, int length, long retryIntervalM
         return retry(() -> read(dst, position, length), retryIntervalMillis, retryTimeoutMillis);
     }
 
-    private void retry(IORunnable runnable, long retryIntervalMillis, long retryTimeoutMillis) throws IOException {
+    protected void retry(IORunnable runnable, long retryIntervalMillis, long retryTimeoutMillis) throws IOException {
         retry(IOSupplier.from(runnable), retryIntervalMillis, retryTimeoutMillis);
     }
 
@@ -106,7 +106,7 @@ private <T> T retry(IOSupplier<T> supplier, long retryIntervalMillis, long retry
         }
     }
 
-    private void checkFailed() throws IOException {
+    protected void checkFailed() throws IOException {
         if (failed) {
             IOException e = new IOException("Failed to execute IO operation, WAL failed");
             LOGGER.error("Failed to execute IO operation, WAL failed", e);