提交 12a01a88 编写于 作者: C Cary Xu

fix: race condition between fetch all and optr serialize

上级 66199e4e
......@@ -1715,7 +1715,8 @@ int32_t tdRSmaProcessExecImpl(SSma *pSma, ERsmaExecType type) {
smaDebug("vgId:%d, batchSize:%d, execType:%" PRIi8, SMA_VID(pSma), qallItemSize, type);
}
if (type == RSMA_EXEC_OVERFLOW) {
if (((type == RSMA_EXEC_OVERFLOW) && (atomic_load_8(RSMA_COMMIT_STAT(pRSmaStat)) == 0)) ||
(type == RSMA_EXEC_COMMIT)) {
tdRSmaFetchAllResult(pSma, pInfo, pSubmitArr);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册