diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index abef7270406fa660d9c177276f3038f920b57159..8a645d5761b0e935a4051d66c13b68869739708e 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -261,6 +261,7 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) {
   SSqlCmd *pCmd = &pSql->cmd;
 
   assert(*pSql->self == pSql);
+  pSql->pRpcCtx = NULL;
 
   if (pObj->signature != pObj) {
     tscDebug("%p DB connection is closed, cmd:%d pObj:%p signature:%p", pSql, pCmd->command, pObj, pObj->signature);
@@ -398,7 +399,6 @@ void tscProcessMsgFromServer(SRpcMsg *rpcMsg, SRpcEpSet *pEpSet) {
   }
 
   rpcFreeCont(rpcMsg->pCont);
-
 }
 
 int doProcessSql(SSqlObj *pSql) {