fix(stream): remove invalid code.

This commit is contained in:
Haojun Liao 2023-07-29 19:23:35 +08:00
parent 94551e6e46
commit 399088e2bd
1 changed files with 0 additions and 2 deletions

View File

@ -1563,8 +1563,6 @@ static void doBlockDataWindowFilter(SSDataBlock* pBlock, int32_t tsIndex, STimeW
ASSERT(pCol->pData != NULL); ASSERT(pCol->pData != NULL);
for (int32_t i = 0; i < pBlock->info.rows; ++i) { for (int32_t i = 0; i < pBlock->info.rows; ++i) {
int64_t* ts = (int64_t*)colDataGetData(pCol, i); int64_t* ts = (int64_t*)colDataGetData(pCol, i);
printf("-------------------%"PRId64"\n", *ts);
p[i] = (*ts >= pWindow->skey); p[i] = (*ts >= pWindow->skey);
if (!p[i]) { if (!p[i]) {