From 51a6aa51cda1924cc6f811975ea18c8e8d856a6d Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Wed, 21 Dec 2022 20:23:00 +0800 Subject: [PATCH] fix:modify delete msg type to tmq meta --- source/client/src/clientTmq.c | 4 ---- 1 file changed, 4 deletions(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index c63ddea25d..bdba83cbb2 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -1911,10 +1911,6 @@ tmq_res_t tmq_get_res_type(TAOS_RES* res) { if (TD_RES_TMQ(res)) { return TMQ_RES_DATA; } else if (TD_RES_TMQ_META(res)) { - SMqMetaRspObj* pMetaRspObj = (SMqMetaRspObj*)res; - if (pMetaRspObj->metaRsp.resMsgType == TDMT_VND_DELETE) { - return TMQ_RES_DATA; - } return TMQ_RES_TABLE_META; } else if (TD_RES_TMQ_METADATA(res)) { return TMQ_RES_METADATA;