enh: not fetch all during commit

8f6e8759 · Cary Xu · 12a01a88 · 8f6e8759
显示空白变更内容
内联并排

Showing with 1 addition and 2 deletion

source/dnode/vnode/src/sma/smaRollup.c source/dnode/vnode/src/sma/smaRollup.c +1 -2

未找到文件。
--- 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)) ||
+              if (atomic_load_8(RSMA_COMMIT_STAT(pRSmaStat)) == 0) {
-                  (type == RSMA_EXEC_COMMIT)) {
                tdRSmaFetchAllResult(pSma, pInfo, pSubmitArr);
              }