diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index 9f15e2d93772a6b2a919edbd0e305351a7840291..0d13e5365a6aa7a4deff318b422bfb430b4617fa 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -1157,11 +1157,6 @@ static void sum_func_merge(SQLFunctionCtx *pCtx) {
     }
   }
 
-  // support always return value option
-  if(notNullElems == 0 && tsAggAlways) {
-    notNullElems = 1;
-  }
-
   SET_VAL(pCtx, notNullElems, 1);
   SResultRowCellInfo *pResInfo = GET_RES_INFO(pCtx);