diff --git a/source/libs/parser/src/parInsertSql.c b/source/libs/parser/src/parInsertSql.c
index 13d040cb0cfe371568a0187527a212b2c518d49e..6f6c28e8b4a829da54c52a89915d6bafe0baa18c 100644
--- a/source/libs/parser/src/parInsertSql.c
+++ b/source/libs/parser/src/parInsertSql.c
@@ -847,7 +847,7 @@ static int32_t getTableMetaAndVgroup(SInsertParseContext* pCxt, SVnodeModifOpStm
   SParseContext* pComCxt = pCxt->pComCxt;
   int32_t        code = TSDB_CODE_SUCCESS;
   if (pComCxt->async) {
-    code = getTableMetaAndVgroupImpl(pComCxt->pCatalog, pStmt, pMissCache);
+    code = getTableMetaAndVgroupImpl(pComCxt, pStmt, pMissCache);
   } else {
     code = getTableMeta(pCxt, &pStmt->targetTableName, false, &pStmt->pTableMeta, pMissCache);
     if (TSDB_CODE_SUCCESS == code && !pCxt->missCache) {