incorrect query result gets by stream agg hint

[wjhuang2016]

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

[AilinKid]

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]

@XuHuaiyu /cc

[XuHuaiyu]

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]

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