This is an automated cherry-pick of pingcap#48839

Signed-off-by: ti-chi-bot <[email protected]>
ti-chi-bot · Nov 29, 2023 · 617f6ce · 617f6ce
1 parent 877198d
commit 617f6ce
Show file tree

Hide file tree

Showing 3 changed files with 580 additions and 0 deletions.
diff --git a/executor/cte.go b/executor/cte.go
@@ -543,6 +543,16 @@ func (p *cteProducer) computeChunkHash(chk *chunk.Chunk) (sel []int, err error)
 			hashBitMap[val] = true
 		}
 	} else {
+		// Length of p.sel is init as MaxChunkSize, but the row num of chunk may still exceeds MaxChunkSize.
+		// So needs to handle here to make sure len(p.sel) == chk.NumRows().
+		if len(p.sel) < numRows {
+			tmpSel := make([]int, numRows-len(p.sel))
+			for i := 0; i < len(tmpSel); i++ {
+				tmpSel[i] = i + len(p.sel)
+			}
+			p.sel = append(p.sel, tmpSel...)
+		}
+
 		// All rows is selected, sel will be [0....numRows).
 		// e.sel is setup when building executor.
 		sel = p.sel