From e671e872342bd5e9c93b91da0c96ade4624303df Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 22 Sep 2023 23:06:48 +0800
Subject: [PATCH] fix(stream): fix invalid assert.

---
 source/dnode/vnode/src/tq/tq.c  | 2 +-
 source/libs/stream/src/stream.c | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index 677e71efd3..5d8a778453 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -1593,7 +1593,7 @@ FAIL:
   }
 
   pRspHead->vgId = htonl(req.upstreamNodeId);
-  ASSERT(pRspHead->vgId > 0);
+  ASSERT(pRspHead->vgId != 0);
 
   SStreamDispatchRsp* pRsp = POINTER_SHIFT(pRspHead, sizeof(SMsgHead));
   pRsp->streamId = htobe64(req.streamId);
diff --git a/source/libs/stream/src/stream.c b/source/libs/stream/src/stream.c
index 2891c93e9b..888c9113d5 100644
--- a/source/libs/stream/src/stream.c
+++ b/source/libs/stream/src/stream.c
@@ -140,7 +140,7 @@ static int32_t buildDispatchRsp(const SStreamTask* pTask, const SStreamDispatchR
   }
 
   ((SMsgHead*)(*pBuf))->vgId = htonl(pReq->upstreamNodeId);
-  ASSERT(((SMsgHead*)(*pBuf))->vgId > 0);
+  ASSERT(((SMsgHead*)(*pBuf))->vgId != 0);
 
   SStreamDispatchRsp* pDispatchRsp = POINTER_SHIFT((*pBuf), sizeof(SMsgHead));