diff --git a/source/dnode/vnode/src/sma/smaRollup.c b/source/dnode/vnode/src/sma/smaRollup.c index 5b2595ad21017354e64becac25172867403bae97..3ed8dc2a20ac4c5f138f8e760383fa6303bb23f7 100644 --- a/source/dnode/vnode/src/sma/smaRollup.c +++ b/source/dnode/vnode/src/sma/smaRollup.c @@ -1715,8 +1715,7 @@ int32_t tdRSmaProcessExecImpl(SSma *pSma, ERsmaExecType type) { smaDebug("vgId:%d, batchSize:%d, execType:%" PRIi8, SMA_VID(pSma), qallItemSize, type); } - if (((type == RSMA_EXEC_OVERFLOW) && (atomic_load_8(RSMA_COMMIT_STAT(pRSmaStat)) == 0)) || - (type == RSMA_EXEC_COMMIT)) { + if (atomic_load_8(RSMA_COMMIT_STAT(pRSmaStat)) == 0) { tdRSmaFetchAllResult(pSma, pInfo, pSubmitArr); }