diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 8cc28bb2ca8a8ce678dceab83c05dd1ff73d250b..b7459b00dace1b3ba44482742e11f1f3d99b4da1 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -3393,7 +3393,7 @@ int tscRenewTableMeta(SSqlObj *pSql) { SSqlCmd* pCmd2 = &pSql->rootObj->cmd; SHashObj *pmap = pCmd2->pTableMetaMap; if (pmap == atomic_val_compare_exchange_ptr(&pCmd2->pTableMetaMap, pmap, NULL)) { - tscCleanupTableMetaMap(pCmd2->pTableMetaMap); + tscCleanupTableMetaMap(pmap); } pCmd2->pTableMetaMap = taosHashInit(4, taosGetDefaultHashFunction(TSDB_DATA_TYPE_BINARY), false, HASH_ENTRY_LOCK); diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c index 766e3e340f398ba94dbbd6de3d24e185ff6c6035..6e29d6ddc3facdfac745557b49f31d80a4a2cb11 100644 --- a/src/client/src/tscUtil.c +++ b/src/client/src/tscUtil.c @@ -1653,7 +1653,7 @@ void tscResetSqlCmd(SSqlCmd* pCmd, bool clearCachedMeta, uint64_t id) { tscFreeQueryInfo(pCmd, clearCachedMeta, id); SHashObj *pmap = pCmd->pTableMetaMap; if (pmap == atomic_val_compare_exchange_ptr(&pCmd->pTableMetaMap, pmap, NULL)) { - tscCleanupTableMetaMap(pCmd->pTableMetaMap); + tscCleanupTableMetaMap(pmap); } taosReleaseRef(tscObjRef, id); }