fix(query): set correct scan flag.
This commit is contained in:
parent
6482ef9ad1
commit
3ac1ce69b6
|
@ -277,13 +277,14 @@ static ERetType extractScanInfo(SOperatorInfo* pOperator, STraverParam* pParam,
|
||||||
}
|
}
|
||||||
|
|
||||||
int32_t getTableScanInfo(SOperatorInfo* pOperator, int32_t* order, int32_t* scanFlag, bool inheritUsOrder) {
|
int32_t getTableScanInfo(SOperatorInfo* pOperator, int32_t* order, int32_t* scanFlag, bool inheritUsOrder) {
|
||||||
SExtScanInfo info = {.inheritUsOrder = inheritUsOrder};
|
SExtScanInfo info = {.inheritUsOrder = inheritUsOrder, .order = *order};
|
||||||
STraverParam p = {.pParam = &info};
|
STraverParam p = {.pParam = &info};
|
||||||
|
|
||||||
traverseOperatorTree(pOperator, extractScanInfo, &p, NULL);
|
traverseOperatorTree(pOperator, extractScanInfo, &p, NULL);
|
||||||
*order = info.order;
|
*order = info.order;
|
||||||
*scanFlag = info.scanFlag;
|
*scanFlag = info.scanFlag;
|
||||||
|
|
||||||
|
ASSERT(*order == TSDB_ORDER_ASC || *order == TSDB_ORDER_DESC);
|
||||||
return p.code;
|
return p.code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue