diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c index 0dff717fe4..3e90a1567c 100644 --- a/src/client/src/tscSubquery.c +++ b/src/client/src/tscSubquery.c @@ -930,9 +930,7 @@ static void joinRetrieveFinalResCallback(void* param, TAOS_RES* tres, int numOfR pSql->cmd.command = TSDB_SQL_SELECT; pSql->fp = tscJoinQueryCallback; - atomic_add_fetch_32(&pState->numOfRemain, 1); tscProcessSql(pSql); - return; } }