diff --git a/matview.c b/matview.c index e778b1f..9212c8f 100644 --- a/matview.c +++ b/matview.c @@ -2063,7 +2063,7 @@ apply_delta(Oid matviewOid, Tuplestorestate *old_tuplestores, Tuplestorestate *n /* apply new delta */ if (use_count) apply_new_delta_with_count(matviewname, NEW_DELTA_ENRNAME, - keys, aggs_set_new, &target_list_buf, count_colname, + keys, &target_list_buf, aggs_set_new, count_colname, query->distinctClause != NULL); else apply_new_delta(matviewname, NEW_DELTA_ENRNAME, &target_list_buf); @@ -2547,7 +2547,7 @@ apply_old_delta(const char *matviewname, const char *deltaname_old, */ static void apply_new_delta_with_count(const char *matviewname, const char* deltaname_new, - List *keys, StringInfo aggs_set, StringInfo target_list, + List *keys, StringInfo target_list, StringInfo aggs_set, const char* count_colname, bool distinct) { StringInfoData querybuf;