diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c
index 8f9e88dde873ed8b9534491f75513655dcb65bfd..847ce1c51072e259ec3d27721f4f3fe648eb914c 100644
--- a/src/client/src/tscUtil.c
+++ b/src/client/src/tscUtil.c
@@ -1343,7 +1343,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) {