[CMIT] 修复sonic hash agg对于count(*)的隐患

2024-11-08 05:34:40 +00:00
parent 94a4b0c4ab
commit cf24682a67
1 changed files with 2 additions and 2 deletions
--- a/src/gausskernel/runtime/vecexecutor/vectorsonic/vsonichashagg.cpp
+++ b/src/gausskernel/runtime/vecexecutor/vectorsonic/vsonichashagg.cpp
@ -557,8 +557,8 @@ void SonicHashAgg::initAggInfo()
        m_aggIdx[j] = aggIdx;

        /* mark count(col), count(*) */
-        if (m_runtime->aggInfo[j].vec_agg_function.flinfo->fn_addr == int8inc_any ||
-            m_runtime->aggInfo[j].vec_agg_function.flinfo->fn_addr == int8inc) {
+        Oid aggFuncOid = m_runtime->aggInfo[j].vec_agg_function.flinfo->fn_oid;
+        if (aggFuncOid == F_INT8INC || aggFuncOid == F_INT8INC_ANY) {
            m_aggCount[j] = true;
        }