diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 0a67787be3d4808d278ae341068eb8f24364a50b..1baee971cfe911402cbf556b4b3e63dee455a8e4 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -1482,7 +1482,7 @@ void handleDownstreamOperator(SSqlObj** pSqlObjList, int32_t numOfUpstream, SQue
 
       // set input data order to param[1]
       if(pex->base.functionId == TSDB_FUNC_FIRST || pex->base.functionId  ==  TSDB_FUNC_FIRST_DST ||
-         pex->base.functionId == TSDB_FUNC_LAST  || pex->base.functionId  ==  TSDB_FUNC_LAST) {
+         pex->base.functionId == TSDB_FUNC_LAST  || pex->base.functionId  ==  TSDB_FUNC_LAST_DST) {
         // set input order
         SQueryInfo* pInputQI = pSqlObjList[0]->cmd.pQueryInfo;
         if(pInputQI) {