diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index a94e9793d86c0244e5c11213198ab4a9dd8d4663..385294c25dbbdc3ca4b47e551fc16bc1170db757 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -1947,7 +1947,6 @@ int tscProcessRetrieveGlobalMergeRsp(SSqlObj *pSql) {
   SQueryInfo *pQueryInfo = tscGetQueryInfo(pCmd);
   if (pQueryInfo->pQInfo == NULL) {
     STableGroupInfo tableGroupInfo = {.numOfTables = 1, .pGroupList = taosArrayInit(1, POINTER_BYTES),};
-    tableGroupInfo.map = taosHashInit(1, taosGetDefaultHashFunction(TSDB_DATA_TYPE_INT), true, HASH_NO_LOCK);
 
     STableKeyInfo tableKeyInfo = {.pTable = NULL, .lastKey = INT64_MIN};
 
diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index e40971d8e4dfb36af30bf4fc2c82f371de36b41a..dfbe4441463a3a3e18c50955110bcc368549217d 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -1405,8 +1405,6 @@ void handleDownstreamOperator(SSqlObj** pSqlObjList, int32_t numOfUpstream, SQue
       }
     }
 
-    tableGroupInfo.map = taosHashInit(1, taosGetDefaultHashFunction(TSDB_DATA_TYPE_INT), true, HASH_NO_LOCK);
-
     STableKeyInfo tableKeyInfo = {.pTable = NULL, .lastKey = INT64_MIN};
 
     SArray* group = taosArrayInit(1, sizeof(STableKeyInfo));