incorrect query result gets by stream agg hint #49902

wjhuang2016 · 2023-12-29T04:41:56Z

Bug Report

Please answer these questions before submitting your issue. Thanks!

1. Minimal reproduce step (Required)

CREATE TABLE `t6b2b5228` (
  `col_60` varchar(27) CHARACTER SET utf8 COLLATE utf8_unicode_ci NOT NULL,
  `col_61` time NOT NULL DEFAULT '20:33:39',
  UNIQUE KEY `idx_26` (`col_61`,`col_60`(5)),
  KEY `idx_27` (`col_61`,`col_60`),
  KEY `idx_28` (`col_60`,`col_61`),
  PRIMARY KEY (`col_61`,`col_60`(5)) /*T![clustered_index] CLUSTERED */
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
INSERT INTO `t6b2b5228` VALUES ('VV$oZob0FJ+==qTb','00:17:18'), ('VV$oZob0FJ+==qTb','00:28:47'), ('!','00:39:34'), ('','00:59:55'), ('VV$oZob0FJ+==qTb','01:16:30'), ('(46raVJ*NT5@q=8','01:21:01'), ('VV$oZob0FJ+==qTb','01:23:19'), ('VV$oZob0FJ+==qTb','01:35:10'), ('VV$oZob0FJ+==qTb','01:44:47'), ('N','01:55:29'), ('VV$oZob0FJ+==qTb','02:21:27'), ('Ju$UWkLPm2S','02:31:23'), ('VV$oZob0FJ+==qTb','02:31:55'), ('VV$oZob0FJ+==qTb','02:36:55'), ('VV$oZob0FJ+==qTb','02:59:51'), ('VV$oZob0FJ+==qTb','03:02:15'), ('','03:14:12'), ('~gYMnP','03:15:07'), ('VV$oZob0FJ+==qTb','03:17:08'), ('&TGP','03:26:39'), ('(atO_ui','03:42:02'), ('qa2XQtJ=q+o','04:29:46'), ('vB23070uaDVrnmp6W','05:27:09'), ('VV$oZob0FJ+==qTb','06:03:18'), ('lPjU%-Z','06:13:54'), (')(pYi98w','07:15:44'), ('(4zdfNLyJ','07:40:56'), ('VV$oZob0FJ+==qTb','07:56:47'), ('tFA7zs&H!o%Go0G4yH','08:00:39'), ('VV$oZob0FJ+==qTb','08:12:01'), ('VV$oZob0FJ+==qTb','08:21:37'), ('7~*MQ=nJP','08:27:39'), ('u9^!m','08:55:04'), ('VV$oZob0FJ+==qTb','08:56:31'), ('VV$oZob0FJ+==qTb','09:07:50'), ('VV$oZob0FJ+==qTb','09:11:32'), ('VV$oZob0FJ+==qTb','09:47:58'), ('VV$oZob0FJ+==qTb','10:21:36'), ('Ud5+Rq*','10:23:15'), ('VV$oZob0FJ+==qTb','10:25:21'), ('VV$oZob0FJ+==qTb','10:26:25'), ('VV$oZob0FJ+==qTb','10:50:00'), ('VV$oZob0FJ+==qTb','11:01:07'), ('VV$oZob0FJ+==qTb','11:59:20'), ('VV$oZob0FJ+==qTb','12:26:49'), ('+nCqNXsS$uF&g90sx','12:30:52'), ('v','12:52:11'), ('VV$oZob0FJ+==qTb','12:55:18'), ('VV$oZob0FJ+==qTb','13:02:25'), ('Y4xD*2(+i+JkSSiBSH','13:22:18'), ('VV$oZob0FJ+==qTb','13:25:37'), ('4P!&UVxx=p~t8GdN_XX','13:31:13'), ('(%nqbZ','13:42:55'), ('VV$oZob0FJ+==qTb','13:57:31'), ('nzH+m&P7Crug0QrLE','14:02:56'), ('VV$oZob0FJ+==qTb','14:10:49'), ('','14:34:24'), (')GmfMl837','14:35:05'), ('v-7FtR&GpIdovDeB','15:04:26'), ('VV$oZob0FJ+==qTb','15:04:33'), ('VV$oZob0FJ+==qTb','15:06:53'), ('VV$oZob0FJ+==qTb','15:15:30'), ('VV$oZob0FJ+==qTb','15:18:04'), ('VV$oZob0FJ+==qTb','15:35:16'), ('VV$oZob0FJ+==qTb','15:49:49'), ('VV$oZob0FJ+==qTb','15:52:18'), ('gTAT7MApl9','15:59:08'), ('VV$oZob0FJ+==qTb','16:02:51'), ('VV$oZob0FJ+==qTb','16:03:49'), ('VV$oZob0FJ+==qTb','16:12:31'), ('VV$oZob0FJ+==qTb','16:14:12'), ('VV$oZob0FJ+==qTb','16:37:27'), ('VV$oZob0FJ+==qTb','16:52:31'), ('VV$oZob0FJ+==qTb','16:54:41'), ('VV$oZob0FJ+==qTb','17:01:29'), ('-','17:22:04'), ('VV$oZob0FJ+==qTb','17:22:17'), ('VV$oZob0FJ+==qTb','17:41:26'), (')snjWA=L','17:43:51'), ('VV$oZob0FJ+==qTb','17:48:33'), ('L0ai9HVPUZ+i','17:56:14'), ('VV$oZob0FJ+==qTb','18:01:29'), ('VV$oZob0FJ+==qTb','18:03:51'), ('VV$oZob0FJ+==qTb','18:11:08'), ('pzm(Kpk3sz-AJA','18:24:29'), ('Jx-j)J~A5z_#(&&U','18:26:59'), ('VV$oZob0FJ+==qTb','18:57:16'), ('z~V#TT!xvVAPK0i9l','19:05:46'), ('VV$oZob0FJ+==qTb','19:14:15'), ('VV$oZob0FJ+==qTb','19:31:07'), ('VV$oZob0FJ+==qTb','19:38:20'), ('VV$oZob0FJ+==qTb','19:44:36'), ('VV$oZob0FJ+==qTb','19:54:17'), (')jWb)$tA0Jkp','20:03:47'), ('VV$oZob0FJ+==qTb','20:21:16'), ('VV$oZob0FJ+==qTb','20:25:57'), ('VV$oZob0FJ+==qTb','20:30:29'), ('VV$oZob0FJ+==qTb','20:37:05'), ('VV$oZob0FJ+==qTb','20:52:18'), ('VV$oZob0FJ+==qTb','20:55:50'), ('VV$oZob0FJ+==qTb','20:58:22'), ('%pwKcQ','21:04:08'), ('H6!KqnZcGy)PJLCIYU','21:13:28'), ('VV$oZob0FJ+==qTb','21:14:13'), ('VV$oZob0FJ+==qTb','21:17:08'), ('VV$oZob0FJ+==qTb','21:24:34'), ('VV$oZob0FJ+==qTb','21:35:33'), ('VV$oZob0FJ+==qTb','21:50:05'), ('VV$oZob0FJ+==qTb','21:53:40'), ('q','21:58:10'), ('VV$oZob0FJ+==qTb','22:07:46'), ('w!P1Y0tRO#m','22:28:16'), ('VV$oZob0FJ+==qTb','22:51:45'), ('VV$oZob0FJ+==qTb','23:02:44'), ('VV$oZob0FJ+==qTb','23:15:04'), ('','23:21:52'), ('VV$oZob0FJ+==qTb','23:24:40'), ('P1xvPuYH$3vRo1Bpg','23:55:56');

CREATE TABLE `t95144843` (
  `col_32` char(129) CHARACTER SET gbk COLLATE gbk_chinese_ci NOT NULL DEFAULT 'ZFOO奆D靖Il!非5',
  `col_33_2` datetime NOT NULL DEFAULT '2019-10-21 00:00:00',
  PRIMARY KEY (`col_32`(3),`col_33_2`) /*T![clustered_index] CLUSTERED */
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_general_ci;
INSERT INTO `t95144843` VALUES ('','1979-12-19 00:00:00'), ('','1997-12-20 00:00:00'), ('','2031-01-03 00:00:00'), ('','2034-08-19 00:00:00'), ('!e','2020-05-11 00:00:00'), ('&+e&ap蠬9273-jSoQ','1985-04-19 00:00:00'), (')K','1992-11-02 00:00:00'), ('+D','2008-07-24 00:00:00'), ('-瀌戞LH繷+%sR+V9a玀f','1972-01-12 00:00:00'), ('3孲Aa萮靚','1974-03-11 00:00:00'), ('55Kp幷YhY5QS=r伅_ig爔=','1979-01-30 00:00:00'), ('9eU燩嘊嚖PT','2028-01-18 00:00:00'), ('9饒攬8','1982-03-26 00:00:00'), ('=*-','2008-11-10 00:00:00'), ('=M3H','2014-11-06 00:00:00'), ('=撦S鼒sSFS*g兾oKR搕a','2034-11-19 00:00:00'), ('A睒','2029-11-21 00:00:00'), ('bY輵秲塹','1989-05-31 00:00:00'), ('dw灰3wvX*槝Kd慴dB&C','2020-06-03 00:00:00'), ('e-5a)Y7D壏零Ru迉窽!m','1976-06-19 00:00:00'), ('E_d&赐蟠乯q向樾$d%Y-D','2010-07-28 00:00:00'), ('GU','2032-01-22 00:00:00'), ('l_l毚','2017-02-24 00:00:00'), ('mi1赞乚zg#w','1990-06-16 00:00:00'), ('O%啹H颖芗','2014-03-31 00:00:00'), ('q鳎A*_鱯胵T4罋v噛d臛','1981-08-09 00:00:00'), ('R暋OH峕D夹ZT垛!虔x8%茯','1980-05-21 00:00:00'), ('t','1998-09-29 00:00:00'), ('V','2026-08-07 00:00:00'), ('v','2029-02-08 00:00:00'), ('WE1鑋b绸尥Y1Vh1DTF^','1979-01-31 00:00:00'), ('Y3((mFY湎wc$','2017-07-26 00:00:00'), ('~莈tPbIb3r敡楻','2021-07-25 00:00:00'), ('y飍鎉*#垷T','2024-07-03 00:00:00'), ('ze(n_)栽齧曅','1984-03-20 00:00:00'), ('湐p聝嫛铢3^uu','2009-05-26 00:00:00'), ('采砅畅俛aC塬1君','1998-05-20 00:00:00'), ('橕z硱唻吱dk矰S)d','1985-12-27 00:00:00'), ('訛','1989-03-27 00:00:00'), ('鵋l笗','1996-01-13 00:00:00'), ('奬h傰贱','2032-08-18 00:00:00'), ('昽d兩#hN悻杲','2019-08-26 00:00:00'), ('峷7S^鑙t','2035-11-05 00:00:00'), ('煟狺YaF','1973-04-13 00:00:00'), ('吻F嵿D)pTg','1992-12-13 00:00:00'), ('绣bAY~咤妰沖犜曈','2016-11-12 00:00:00'), ('柷','2022-01-24 00:00:00'), ('最騺踯l砢W雠#3措C慼Cmg9','1996-07-20 00:00:00');


SELECT /*+ STREAM_AGG()*/ BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';

SELECT  BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';

2. What did you expect to see? (Required)

Two queries gets the same result.

3. What did you see instead (Required)

mysql> SELECT /*+ STREAM_AGG()*/ BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';
+--------+
| r0     |
+--------+
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
|  78610 |
|  78610 |
| 234206 |
| 234206 |
+--------+
21 rows in set (0.01 sec)

mysql> SELECT  BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';
+--------+
| r0     |
+--------+
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
| 234206 |
|      0 |
| 234206 |
+--------+
20 rows in set (0.01 sec)

4. What is your TiDB version? (Required)

c52655c

The text was updated successfully, but these errors were encountered:

AilinKid · 2023-12-29T05:14:29Z

tidb> explain analyze SELECT  BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';
+-------------------------------------+---------+---------+-----------+-----------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
| id                                  | estRows | actRows | task      | access object   | execution info                                                                                                                                                                                                                                                                                                                                                      | operator info                                                                                  | memory    | disk    |
+-------------------------------------+---------+---------+-----------+-----------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
| HashAgg_11                          | 1.00    | 20      | root      |                 | time:2.21ms, loops:6, RU:0.972720, partial_worker:{wall_time:2.171125ms, concurrency:5, task_num:3, tot_wait:8.757083ms, tot_exec:1.150084ms, tot_time:9.928001ms, max:2.129167ms, p95:2.129167ms}, final_worker:{wall_time:2.214375ms, concurrency:5, task_num:10, tot_wait:10.749915ms, tot_exec:14.166µs, tot_time:10.769875ms, max:2.167542ms, p95:2.167542ms}  | group by:Column#11, funcs:bit_xor(Column#10)->Column#5                                         | 222.2 KB  | N/A     |
| └─Projection_28                     | 141.60  | 2478    | root      |                 | time:1.87ms, loops:4, Concurrency:OFF                                                                                                                                                                                                                                                                                                                               | cast(test.t6b2b5228.col_61, bigint(10) BINARY)->Column#10, test.t95144843.col_32->Column#11    | 71.2 KB   | N/A     |
|   └─Projection_13                   | 141.60  | 2478    | root      |                 | time:675.1µs, loops:4, Concurrency:OFF                                                                                                                                                                                                                                                                                                                              | test.t6b2b5228.col_61, test.t95144843.col_32                                                   | 71.5 KB   | N/A     |
|     └─HashJoin_15                   | 141.60  | 2478    | root      |                 | time:631.3µs, loops:4, build_hash_table:{total:127.3µs, fetch:117.1µs, build:10.2µs}, probe:{concurrency:5, total:1.75ms, max:1.23ms, probe:1.11ms, fetch:645.4µs}                                                                                                                                                                                                  | CARTESIAN inner join                                                                           | 17.5 KB   | 0 Bytes |
|       ├─TableReader_18(Build)       | 1.20    | 21      | root      |                 | time:50.9µs, loops:2, cop_task: {num: 1, max: 641.6µs, proc_keys: 0, rpc_num: 1, rpc_time: 589.5µs, copr_cache_hit_ratio: 0.00, build_task_duration: 25.4µs, max_distsql_concurrency: 1}                                                                                                                                                                            | data:Selection_17                                                                              | 641 Bytes | N/A     |
|       │ └─Selection_17              | 1.20    | 21      | cop[tikv] |                 | tikv_task:{time:538.3µs, loops:0}                                                                                                                                                                                                                                                                                                                                   | ge(test.t95144843.col_32, "6(!2QW+凊麩SXNjoWq湿舃"), le(tes5144843.col_32, "~O3K弣6")      | N/A       | N/A     |
|       │   └─TableRangeScan_16       | 1.20    | 21      | cop[tikv] | table:t95144843 | tikv_task:{time:538.3µs, loops:0}                                                                                                                                                                                                                                                                                                                                   | range:["6(!","YO3"], keep order:false, stats:partial[ID 3:unInitialized]                       | N/A       | N/A     |
|       └─TableReader_20(Probe)       | 118.00  | 118     | root      |                 | time:107.8µs, loops:2, cop_task: {num: 1, max: 540.3µs, proc_keys: 0, rpc_num: 1, rpc_time: 504.4µs, copr_cache_hit_ratio: 0.00, build_task_duration: 1.92µs, max_distsql_concurrency: 1}                                                                                                                                                                           | data:TableFullScan_19                                                                          | 1.14 KB   | N/A     |
|         └─TableFullScan_19          | 118.00  | 118     | cop[tikv] | table:t6b2b5228 | tikv_task:{time:428.7µs, loops:0}                                                                                                                                                                                                                                                                                                                                   | keep order:false                                                                               | N/A       | N/A     |
+-------------------------------------+---------+---------+-----------+-----------------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
9 rows in set (0.01 sec)
tidb> explain analyze SELECT /*+ STREAM_AGG()*/ BIT_XOR(`t6b2b5228`.`col_61`) AS `r0` FROM (`t6b2b5228`) JOIN `t95144843` GROUP BY `t95144843`.`col_32` HAVING `t95144843`.`col_32` BETWEEN '6(!2QW+凊麩SXNjoWq湿舃' AND '~O3K弣6';
+---------------------------------------+---------+---------+-----------+-----------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
| id                                    | estRows | actRows | task      | access object   | execution info                                                                                                                                                                                | operator info                                                                                  | memory    | disk    |
+---------------------------------------+---------+---------+-----------+-----------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
| StreamAgg_15                          | 1.00    | 21      | root      |                 | time:5.4ms, loops:2, RU:0.972720                                                                                                                                                              | group by:Column#11, funcs:bit_xor(Column#10)->Column#5                                         | 36.5 KB   | N/A     |
| └─Projection_33                       | 141.60  | 2478    | root      |                 | time:4.74ms, loops:4, Concurrency:OFF                                                                                                                                                         | cast(test.t6b2b5228.col_61, bigint(10) BINARY)->Column#10, test.t95144843.col_32->Column#11    | 74.4 KB   | N/A     |
|   └─Sort_32                           | 141.60  | 2478    | root      |                 | time:3.38ms, loops:4                                                                                                                                                                          | test.t95144843.col_32                                                                          | 110.7 KB  | 0 Bytes |
|     └─Projection_18                   | 141.60  | 2478    | root      |                 | time:1.21ms, loops:4, Concurrency:OFF                                                                                                                                                         | test.t6b2b5228.col_61, test.t95144843.col_32                                                   | 89.3 KB   | N/A     |
|       └─HashJoin_20                   | 141.60  | 2478    | root      |                 | time:1.21ms, loops:4, build_hash_table:{total:467µs, fetch:439.1µs, build:27.9µs}, probe:{concurrency:5, total:3.21ms, max:1.13ms, probe:598µs, fetch:2.61ms}                                 | CARTESIAN inner join                                                                           | 17.5 KB   | 0 Bytes |
|         ├─TableReader_23(Build)       | 1.20    | 21      | root      |                 | time:301.3µs, loops:2, cop_task: {num: 1, max: 593.2µs, proc_keys: 0, rpc_num: 1, rpc_time: 551.1µs, copr_cache_hit_ratio: 0.00, build_task_duration: 15µs, max_distsql_concurrency: 1}       | data:Selection_22                                                                              | 641 Bytes | N/A     |
|         │ └─Selection_22              | 1.20    | 21      | cop[tikv] |                 | tikv_task:{time:514.3µs, loops:0}                                                                                                                                                             | ge(test.t95144843.col_32, "6(!2QW+凊麩SXNjoWq湿舃"), lst.t95144843.col_32, "~O3K弣6")      | N/A       | N/A     |
|         │   └─TableRangeScan_21       | 1.20    | 21      | cop[tikv] | table:t95144843 | tikv_task:{time:514.3µs, loops:0}                                                                                                                                                             | range:["6(!","YO3"], keep order:false, stats:partial[ID 3:unInitialized]                       | N/A       | N/A     |
|         └─TableReader_25(Probe)       | 118.00  | 118     | root      |                 | time:405.6µs, loops:2, cop_task: {num: 1, max: 469.8µs, proc_keys: 0, rpc_num: 1, rpc_time: 442.7µs, copr_cache_hit_ratio: 0.00, build_task_duration: 2.96µs, max_distsql_concurrency: 1}     | data:TableFullScan_24                                                                          | 1.14 KB   | N/A     |
|           └─TableFullScan_24          | 118.00  | 118     | cop[tikv] | table:t6b2b5228 | tikv_task:{time:409µs, loops:0}                                                                                                                                                               | keep order:false                                                                               | N/A       | N/A     |
+---------------------------------------+---------+---------+-----------+-----------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+------------------------------------------------------------------------------------------------+-----------+---------+
10 rows in set (0.01 sec)

except for the root Operator, the other operators' actual row count is quite the same and desirable, while streamAgg and hashAgg output different row-cout out.

AilinKid · 2023-12-29T05:15:39Z

@XuHuaiyu /cc

XuHuaiyu · 2024-01-02T07:48:54Z

reproducible minor case

step1: modify the tidb code:

diff --git a/pkg/sessionctx/variable/tidb_vars.go b/pkg/sessionctx/variable/tidb_vars.go
index 059b9115a9..26539e9401 100644
--- a/pkg/sessionctx/variable/tidb_vars.go
+++ b/pkg/sessionctx/variable/tidb_vars.go
@@ -1187,10 +1187,10 @@ const (
        DefBatchDelete                                 = false
        DefBatchCommit                                 = false
        DefCurretTS                                    = 0
-       DefInitChunkSize                               = 32
+       DefInitChunkSize                               = 2
        DefMinPagingSize                               = int(paging.MinPagingSize)
        DefMaxPagingSize                               = int(paging.MaxPagingSize)
-       DefMaxChunkSize                                = 1024
+       DefMaxChunkSize                                = 2
        DefDMLBatchSize                                = 0
        DefMaxPreparedStmtCount                        = -1
        DefWaitTimeout                                 = 28800
diff --git a/pkg/sessionctx/variable/varsutil.go b/pkg/sessionctx/variable/varsutil.go
index 8d3262786b..a15d34da0d 100644
--- a/pkg/sessionctx/variable/varsutil.go
+++ b/pkg/sessionctx/variable/varsutil.go
@@ -233,7 +233,7 @@ const (
        // initChunkSizeUpperBound indicates upper bound value of tidb_init_chunk_size.
        initChunkSizeUpperBound = 32
        // maxChunkSizeLowerBound indicates lower bound value of tidb_max_chunk_size.
-       maxChunkSizeLowerBound = 32
+       maxChunkSizeLowerBound = 2
 )
 
 // appendDeprecationWarning adds a warning that the item is deprecated.

step2:

drop table if exists t, s;
CREATE TABLE `t` (`c` char(1)) COLLATE=utf8_general_ci  ;
insert into t values("V"),("v");
CREATE TABLE `s` (`col_61` int);
insert into s values(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1),(1);
SELECT /*+ stream_agg()*/ `t`.`c` FROM (`s`) JOIN `t` GROUP BY `t`.`c`;
SELECT  `t`.`c` FROM (`s`) JOIN `t`  GROUP BY `t`.`c`;

wshwsh12 · 2024-01-02T09:21:57Z

v5.4.0 doesn't use new collation, so don't pick this fix.

close #49902

…50022) close #49902

…50026) close #49902

…50024) close #49902

…50027) close #49902

wjhuang2016 added type/bug This issue is a bug. fuzz/randomtest labels Dec 29, 2023

jebter added sig/execution SIG execution severity/critical labels Dec 29, 2023

ti-chi-bot bot added may-affects-5.4 This bug maybe affects 5.4.x versions. may-affects-6.1 may-affects-6.5 may-affects-7.1 may-affects-7.5 labels Dec 29, 2023

wshwsh12 mentioned this issue Jan 2, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec #49974

Merged

13 tasks

wshwsh12 added affects-6.1 affects-6.5 affects-7.1 affects-7.5 and removed may-affects-5.4 This bug maybe affects 5.4.x versions. labels Jan 2, 2024

ti-chi-bot bot removed may-affects-6.1 may-affects-6.5 may-affects-7.5 may-affects-7.1 labels Jan 2, 2024

ti-chi-bot bot closed this as completed in #49974 Jan 3, 2024

ti-chi-bot bot pushed a commit that referenced this issue Jan 3, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec (#49974)

596276b

close #49902

ti-chi-bot bot pushed a commit that referenced this issue Jan 8, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec (#49974) (#…

102ab31

…50022) close #49902

ti-chi-bot bot pushed a commit that referenced this issue Jan 8, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec (#49974) (#…

061a7da

…50026) close #49902

ti-chi-bot bot pushed a commit that referenced this issue Jan 8, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec (#49974) (#…

6a5b2a3

…50024) close #49902

ti-chi-bot bot pushed a commit that referenced this issue Jan 8, 2024

executor: use EncodeKey to encode groupkey in StreamAggExec (#49974) (#…

4a8c7b2

…50027) close #49902

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

incorrect query result gets by stream agg hint #49902

incorrect query result gets by stream agg hint #49902

wjhuang2016 commented Dec 29, 2023

AilinKid commented Dec 29, 2023 •

edited

Loading

AilinKid commented Dec 29, 2023

XuHuaiyu commented Jan 2, 2024 •

edited

Loading

wshwsh12 commented Jan 2, 2024

incorrect query result gets by stream agg hint #49902

incorrect query result gets by stream agg hint #49902

Comments

wjhuang2016 commented Dec 29, 2023

Bug Report

1. Minimal reproduce step (Required)

2. What did you expect to see? (Required)

3. What did you see instead (Required)

4. What is your TiDB version? (Required)

AilinKid commented Dec 29, 2023 • edited Loading

AilinKid commented Dec 29, 2023

XuHuaiyu commented Jan 2, 2024 • edited Loading

wshwsh12 commented Jan 2, 2024

AilinKid commented Dec 29, 2023 •

edited

Loading

XuHuaiyu commented Jan 2, 2024 •

edited

Loading