From 12a01a88dd2cf189aa702ce40758e9f11dafcede Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Mon, 29 Aug 2022 16:15:12 +0800 Subject: [PATCH] fix: race condition between fetch all and optr serialize --- source/dnode/vnode/src/sma/smaRollup.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/sma/smaRollup.c b/source/dnode/vnode/src/sma/smaRollup.c index 426ab521fd..5b2595ad21 100644 --- a/source/dnode/vnode/src/sma/smaRollup.c +++ b/source/dnode/vnode/src/sma/smaRollup.c @@ -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); }