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));