admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 01:28:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: use remote wal when local wal shutdown (#45753)

Browse Source 
issue: #45750

Signed-off-by: chyezh <chyezh@outlook.com>
This commit is contained in:
Zhen Ye 2025-11-22 16:17:05 +08:00 committed by GitHub
parent eea9c8093d
commit 823c7f7e3e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/streamingnode/client/handler/handler_client_impl.go
View File

@ -298,7 +298,7 @@ func shouldUseRemoteWAL(err error) bool {
if errors.Is(err, registry.ErrNoStreamingNodeDeployed) { if errors.Is(err, registry.ErrNoStreamingNodeDeployed) {
return true 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) streamingServiceErr := status.AsStreamingError(err)
return streamingServiceErr.IsWrongStreamingNode() return streamingServiceErr.IsWrongStreamingNode() || streamingServiceErr.IsOnShutdown()
} }