diff --git a/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java b/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java
index 3a74dd0e..94e68a16 100644
--- a/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java
+++ b/client/src/main/java/io/streamnative/oxia/client/grpc/WriteStreamWrapper.java
@@ -93,7 +93,7 @@ public void onError(Throwable ex) {
                         pendingWrites.size(),
                         completedException);
             }
-            pendingWrites.forEach(f -> f.completeExceptionally(ex));
+            pendingWrites.forEach(f -> f.completeExceptionally(completedException));
             pendingWrites.clear();
         } finally {
             statusLock.unlockWrite(stamp);