Commit a68c8df
authored
[Bug](agg-state) fix agg state inner type not conversioned (#50418)
### What problem does this PR solve?
drop table if exists t01;
create table t01(id int, decimal_col agg_state<sum(decimal(20,6))>
generic) properties ("replication_num" = "1");
insert into t01 values (1, sum_state(10.1)), (1, sum_state(20.1)), (2,
sum_state(10.2)), (2, sum_state(11.0));
select sum_merge(decimal_col) from t01 group by id;
[18:36]MySQL [email protected]:test_agg_state> select
sum_merge(decimal_col) from t01 group by id; (1105, "errCode = 2,
detailMessage =
(172.20.48.119)[INTERNAL_ERROR]AggState(function_name=sum,result_is_nullable=true,arguments=[Nullable(Decimal(27,
9))],be_exec_version=8)'s expect return type is Nullable(Decimal(27,
9)), but input Nullable(Decimal(76, 6))") [18:36]MySQL
[email protected]:test_agg_state>
### Check List (For Author)
- Test <!-- At least one of them must be included. -->
- [x] Regression test
- [ ] Unit Test
- [ ] Manual test (add detailed scripts or steps below)
- [ ] No need to test or manual test. Explain why:
- [ ] This is a refactor/code format and no logic has been changed.
- [ ] Previous test can cover this change.
- [ ] No code files have been changed.
- [ ] Other reason <!-- Add your reason? -->
- Behavior changed:
- [x] No.
- [ ] Yes. <!-- Explain the behavior change -->
- Does this need documentation?
- [x] No.
- [ ] Yes. <!-- Add document PR link here. eg:
apache/doris-website#1214 -->
### Check List (For Reviewer who merge this PR)
- [ ] Confirm the release note
- [ ] Confirm test cases
- [ ] Confirm document
- [ ] Add branch pick label <!-- Add branch pick label that this PR
should merge into -->1 parent 909a95d commit a68c8df
File tree
3 files changed
+42
-0
lines changed- fe/fe-core/src/main/java/org/apache/doris/nereids/types
- regression-test
- data/datatype_p0/agg_state/decimal_sum
- suites/datatype_p0/agg_state/decimal_sum
3 files changed
+42
-0
lines changedLines changed: 6 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
104 | 104 | | |
105 | 105 | | |
106 | 106 | | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
107 | 113 | | |
108 | 114 | | |
109 | 115 | | |
| |||
Lines changed: 5 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
Lines changed: 31 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
0 commit comments