From 92bde5b4f692a724bd4fff143ebb6bdea6ba83e2 Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Fri, 17 Jan 2025 11:47:02 +0800 Subject: [PATCH] fix: panic when streaming release if using msgstream (#39374) issue: #39367 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 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() }