From 25bfcb7908fffd0006886ae8198aac9e6e95fb0a Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 27 Aug 2024 18:44:42 +0800 Subject: [PATCH] fix(query): fix error in test. --- source/libs/executor/test/joinTests.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/test/joinTests.cpp b/source/libs/executor/test/joinTests.cpp index 7d3cf0580c..6dd42c3a93 100755 --- a/source/libs/executor/test/joinTests.cpp +++ b/source/libs/executor/test/joinTests.cpp @@ -2967,7 +2967,8 @@ void runSingleTest(char* caseName, SJoinTestParam* param) { jtCtx.startTsUs = taosGetTimestampUs(); while (true) { - SSDataBlock* pBlock = jtCtx.pJoinOp->fpSet.getNextFn(jtCtx.pJoinOp); + SSDataBlock* pBlock = NULL; + int32_t code = jtCtx.pJoinOp->fpSet.getNextFn(jtCtx.pJoinOp, &pBlock); if (NULL == pBlock) { checkJoinDone(caseName); break;