From 5330fc981ca6f726064e0bc58efed5226901e755 Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Fri, 17 Jan 2025 11:55:03 +0800 Subject: [PATCH] fix: panic when streaming release if using msgstream (#39375) issue: #39367 pr: #39374 Signed-off-by: chyezh --- internal/distributed/streaming/wal.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/distributed/streaming/wal.go b/internal/distributed/streaming/wal.go index af1220dc33..e1410aa16f 100644 --- a/internal/distributed/streaming/wal.go +++ b/internal/distributed/streaming/wal.go @@ -158,7 +158,9 @@ func (w *walAccesserImpl) Close() { } w.producerMutex.Unlock() - w.handlerClient.Close() + if w.handlerClient != nil { + w.handlerClient.Close() + } w.streamingCoordClient.Close() }