xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: fill operator with desc ts order returned 1 more rows

This commit is contained in:
wangjiaming0909 2023-08-23 14:54:41 +08:00
parent ec7614449e
commit 3c8bd57140
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/executor/src/filloperator.c
View File

@ -177,6 +177,7 @@ static void revisedFillStartKey(SFillOperatorInfo* pInfo, SSDataBlock* pBlock, i
} }
// todo time window chosen problem: t or prev value? // todo time window chosen problem: t or prev value?
if (t > pInfo->pFillInfo->start) t -= pInterval->sliding;
taosFillUpdateStartTimestampInfo(pInfo->pFillInfo, t); taosFillUpdateStartTimestampInfo(pInfo->pFillInfo, t);
} }
} }

9
tests/system-test/2-query/fill_with_group.py
View File

@ -130,9 +130,18 @@ class TDTestCase:
for j in range(0,60): for j in range(0,60):
tdSql.checkData(i*1500+j, 1, None) tdSql.checkData(i*1500+j, 1, None)
def test_fill_with_order_by(self):
sql = "select _wstart, _wend, count(ts), sum(c1) from meters where ts > '2018-11-25 00:00:00.000' and ts < '2018-11-26 00:00:00.00' interval(1d) fill(NULL) order by _wstart"
tdSql.query(sql)
tdSql.checkRows(1)
sql = "select _wstart, _wend, count(ts), sum(c1) from meters where ts > '2018-11-25 00:00:00.000' and ts < '2018-11-26 00:00:00.00' interval(1d) fill(NULL) order by _wstart desc"
tdSql.query(sql)
tdSql.checkRows(1)
def run(self): def run(self):
self.prepareTestEnv() self.prepareTestEnv()
self.test_partition_by_with_interval_fill_prev_new_group_fill_error() self.test_partition_by_with_interval_fill_prev_new_group_fill_error()
self.test_fill_with_order_by()
def stop(self): def stop(self):
tdSql.close() tdSql.close()