修复并行查询下agg语句执行结果不一致的问题 · Pull Request !2692 · openGauss/openGauss-server - Gitee.com

开源项目 > 数据库相关 > 数据库服务 &&

已合并

chenxiaobin:fixAgg openGauss:master

创建于 2022-12-26 19:00

【标题】(请简要描述下实现的内容)
修复并行查询下agg语句执行结果不一致的问题
【实现内容】:
设置query_dop>1之后，执行`select count(distinct generate_series(1,2));`会报错，而执行`select count(distinct generate_series(1,2)) from t1;`则不会报错。该pr修复此不一致的行为。
【根因分析】:
当前openGauss并不支持Agg下包含set-returning函数。第二种场景的计划如下：
```
explain select count(distinct generate_series(1,2)) from t1;
                            QUERY PLAN                            
------------------------------------------------------------------
 Aggregate  (cost=57.61..57.62 rows=1 width=16)
   ->  HashAggregate  (cost=47.61..52.61 rows=1000 width=8)
         Group By Key: generate_series(1, 2)
         ->  Seq Scan on t1  (cost=0.00..31.49 rows=2149 width=0)
(4 rows)
```
正常SRF的FuncExpr是挂在Agg下的，在执行阶段时会报错。而在并行查询下，get_count_distinct_param会将该FuncExpr放到最底层的SeqScan下，因此生成的计划树中，位于顶层和第二层的Agg和底层SeqScan都包含该FuncExpr。之后set_plan_references会简化该计划树，将顶层的FuncExpr替换为执行子计划中的输出，也就是第二层Agg，而二层Agg的FuncExpr也替换成底层SeqScan的输出，最终计划树中包含FuncExpr就只存在于SeqScan，而SeqScan是支持执行SRF的，因此能成功执行。
【实现方案】:
在生成查询树阶段，生成Agg时校验是否包含SRF，如果存在，提前报错。
【关联需求或issue】:
https://gitee.com/opengauss/openGauss-server/issues/I6736H
【开发自验报告】:
1. 请附上自验结果(内容或者截图)
![输入图片说明](https://foruda.gitee.com/images/1672052491686960469/308517f1_7717739.png "屏幕截图")
2. 是否可以添加fastcheck测试用例，如是，请补充fastcheck用例
是
3. 是否涉及资料修改，如是，在docs仓库补充资料
否
4. 是否考虑支撑升级和在线扩容等扩展场景
否
5. 是否考虑异常场景/并发场景/前向兼容/性能场景
否
6. 是否对其他模块产生影响
否

【其他说明】:

展开设置折叠设置

审查

审查人员

未设置

测试

未设置

优先级

标签

approved

opengauss-cla/yes

sig/tools

ci-pipeline-failed

ci-pipeline-success

lgtm-totaj

lgtm-wuyujun3

关联 Issue

打开 query_dop 后，agg 语句执行结果不一致

Pull Request 合并后将关闭上述关联 Issue

里程碑

参与者（4）

Cherry-pick 可以将 特定提交（Commit） 从某个分支挑选并应用到另一个分支，实现快速集成特定更改，而无需合并整个分支。

提交列表

Commit SHA	Commit Message

基于 Cherry-pick 后的分支发起 Pull Request

Cherry-pick

C++

1

https://gitee.com/opengauss/openGauss-server.git

git@gitee.com:opengauss/openGauss-server.git

opengauss

openGauss-server

openGauss-server