diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c
index 65703f5b2ec9d1f423b2e36a7f303aa4a1d52f4d..f81bebae3923cdcef5ae195d8fe0dca5d934999a 100644
--- a/src/client/src/tscSQLParser.c
+++ b/src/client/src/tscSQLParser.c
@@ -4025,7 +4025,7 @@ static int32_t checkAndSetJoinCondInfo(SSqlCmd* pCmd, SQueryInfo* pQueryInfo, tS
 
   (*leftNode)->uid = pTableMetaInfo->pTableMeta->id.uid;
   (*leftNode)->tagColId = pTagSchema1->colId;
-  if(pLeft->tokenId == TK_ARROW) {
+  if(pExpr->pLeft->tokenId == TK_ARROW) {
     tstrncpy((*leftNode)->tagJsonKeyName, pExpr->pLeft->pRight->value.pz, TSDB_MAX_JSON_KEY_LEN + 1);
   }
 
@@ -4062,7 +4062,7 @@ static int32_t checkAndSetJoinCondInfo(SSqlCmd* pCmd, SQueryInfo* pQueryInfo, tS
 
   (*rightNode)->uid = pTableMetaInfo->pTableMeta->id.uid;
   (*rightNode)->tagColId = pTagSchema2->colId;
-  if(pRight->tokenId == TK_ARROW) {
+  if(pExpr->pRight->tokenId == TK_ARROW) {
     tstrncpy((*rightNode)->tagJsonKeyName, pRight->pLeft->pRight->value.pz, TSDB_MAX_JSON_KEY_LEN + 1);
   }