diff --git a/src/mnode/src/mgmtShell.c b/src/mnode/src/mgmtShell.c index 66cecbdc3f7b6202f062669436d56e936a4c21d8..67b7a72c2372c363cce1674f37f4f1e84ef7ec3c 100644 --- a/src/mnode/src/mgmtShell.c +++ b/src/mnode/src/mgmtShell.c @@ -430,7 +430,7 @@ static void mgmtProcessUseMsg(SQueuedMsg *pMsg) { * check if we need to add mgmtProcessTableMetaMsg into tranQueue, which will be executed one-by-one. */ static bool mgmtCheckTableMetaMsgReadOnly(SQueuedMsg *pMsg) { - SCMTableInfoMsg *pInfo = (SCMTableInfoMsg *) pMsg; + SCMTableInfoMsg *pInfo = pMsg->pCont; pMsg->pTable = mgmtGetTable(pInfo->tableId); if (pMsg->pTable != NULL) return true;