fix(query): fix error in test.
This commit is contained in:
parent
d3f6892345
commit
25bfcb7908
|
@ -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;
|
||||
|
|
Loading…
Reference in New Issue