diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index 870dad6f379a336355d00d84373e436105ce01ec..2ed3a78104f6038b5017c8684b16a75b726f6268 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -8523,7 +8523,8 @@ SQInfo* createQInfoImpl(SQueryTableMsg* pQueryMsg, SGroupbyExpr* pGroupbyExpr, S } // calc skipOffset - if(pQueryMsg->offset > 0 && TSDB_QUERY_HAS_TYPE(pQueryMsg->queryType, TSDB_QUERY_TYPE_PROJECTION_QUERY)) { + if(pQueryMsg->offset > 0 && TSDB_QUERY_HAS_TYPE(pQueryMsg->queryType, TSDB_QUERY_TYPE_PROJECTION_QUERY) + && pQueryAttr->stableQuery == false) { pQueryAttr->skipOffset = true; for (int32_t i = 0; i < pQueryAttr->numOfCols; ++i) { if (pQueryAttr->tableCols[i].flist.numOfFilters > 0