From 7cc3eeee3d62d790e2adc226460ea6fcc2eabde3 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Tue, 11 Jun 2024 15:03:17 +0800 Subject: [PATCH] fix: first dynamic data filter issue --- source/libs/function/src/builtinsimpl.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/source/libs/function/src/builtinsimpl.c b/source/libs/function/src/builtinsimpl.c index 3fb298e1ea..699865a9bf 100644 --- a/source/libs/function/src/builtinsimpl.c +++ b/source/libs/function/src/builtinsimpl.c @@ -2366,7 +2366,10 @@ EFuncDataRequired firstDynDataReq(void* pRes, SDataBlockInfo* pBlockInfo) { } if (pResult->ts < pBlockInfo->window.skey) { return FUNC_DATA_REQUIRED_NOT_LOAD; - } else if (pResult->ts == pBlockInfo->window.skey && pResult->pkData) { + } else if (pResult->ts == pBlockInfo->window.skey) { + if (NULL == pResult->pkData) { + return FUNC_DATA_REQUIRED_NOT_LOAD; + } if (comparePkDataWithSValue(pResult->pkType, pResult->pkData, pBlockInfo->pks + 0, TSDB_ORDER_ASC) < 0) { return FUNC_DATA_REQUIRED_NOT_LOAD; }