提交 d125bb09 编写于 作者: D dapan1121

fix: merge join reset params issue

上级 8b62c75c
......@@ -658,10 +658,10 @@ static bool mergeJoinGetNextTimestamp(SOperatorInfo* pOperator, int64_t* pLeftTs
pJoinInfo->leftPos = 0;
if (pJoinInfo->pLeft == NULL) {
qError("merge join left got empty block");
setMergeJoinDone(pOperator);
if (pOperator->pOperatorParam && ((SSortMergeJoinOperatorParam*)pOperator->pOperatorParam->value)->initParam) {
leftEmpty = true;
} else {
setMergeJoinDone(pOperator);
return false;
}
} else {
......@@ -680,6 +680,7 @@ static bool mergeJoinGetNextTimestamp(SOperatorInfo* pOperator, int64_t* pLeftTs
} else {
qError("merge join right got block");
if (leftEmpty) {
setMergeJoinDone(pOperator);
return false;
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册