diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index 60287c8e474cc79a827637639cf5f9b42bebb53f..db7a73eec60fedaa85bcf484a8d3b777dccda24a 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -5194,7 +5194,7 @@ static bool unique_function_setup(SQLFunctionCtx *pCtx, SResultRowCellInfo* pRes
 }
 
 static void do_unique_function(SQLFunctionCtx *pCtx, SUniqueFuncInfo *pInfo, TSKEY timestamp, char *pData, char *tag){
-  tValuePair *unique = taosHashGet(pCtx->pUniqueSet, pData, pCtx->inputBytes);
+  UniqueUnit *unique = taosHashGet(pCtx->pUniqueSet, pData, pCtx->inputBytes);
   if (unique == NULL) {
     size_t size = sizeof(UniqueUnit) + pCtx->inputBytes + pCtx->tagInfo.tagsLen;
     char *tmp = pInfo->res + pInfo->num * size;