fix(query): avg/stddev divide 0 handling

TD-16762
2022-06-23 13:58:36 +08:00 · 2022-06-23 13:58:36 +08:00 · cfad058333
parent 044f27bbca
commit cfad058333
1 changed files with 5 additions and 0 deletions
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@ -1774,6 +1774,11 @@ int32_t stddevFinalize(SqlFunctionCtx* pCtx, SSDataBlock* pBlock) {
    pStddevRes->result = sqrt(fabs(pStddevRes->quadraticDSum / ((double)pStddevRes->count) - avg * avg));
  }

+  // check for overflow
+  if (isinf(pStddevRes->result) || isnan(pStddevRes->result)) {
+    GET_RES_INFO(pCtx)->numOfRes = 0;
+  }
+
  return functionFinalize(pCtx, pBlock);
 }