diff --git a/internal/distributed/streaming/wal.go b/internal/distributed/streaming/wal.go
index 052129a1d6..ee585f8bd0 100644
--- a/internal/distributed/streaming/wal.go
+++ b/internal/distributed/streaming/wal.go
@@ -163,7 +163,9 @@ func (w *walAccesserImpl) Close() {
 	}
 	w.producerMutex.Unlock()
 
-	w.handlerClient.Close()
+	if w.handlerClient != nil {
+		w.handlerClient.Close()
+	}
 	w.streamingCoordClient.Close()
 }