From 823c7f7e3ebe0009083e89dfa66c411b492f2040 Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Sat, 22 Nov 2025 16:17:05 +0800 Subject: [PATCH] fix: use remote wal when local wal shutdown (#45753) issue: #45750 Signed-off-by: chyezh --- internal/streamingnode/client/handler/handler_client_impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/streamingnode/client/handler/handler_client_impl.go b/internal/streamingnode/client/handler/handler_client_impl.go index dc51506a62..4909e803de 100644 --- a/internal/streamingnode/client/handler/handler_client_impl.go +++ b/internal/streamingnode/client/handler/handler_client_impl.go @@ -298,7 +298,7 @@ func shouldUseRemoteWAL(err error) bool { if errors.Is(err, registry.ErrNoStreamingNodeDeployed) { return true } - // 2. If the wal is not exist at current streaming node. + // 2. If the wal is not exist at current streaming node or the local wal is shutdown. streamingServiceErr := status.AsStreamingError(err) - return streamingServiceErr.IsWrongStreamingNode() + return streamingServiceErr.IsWrongStreamingNode() || streamingServiceErr.IsOnShutdown() }