inner-1239:avoid thread remaining for group by (#2767)

This commit is contained in:
Collapsar
2021-07-06 17:46:17 +08:00
committed by GitHub
parent 5defb967a8
commit 82ebf4be92
@@ -117,6 +117,8 @@ public class DirectGroupByHandler extends OwnThreadDMLHandler {
localResultReferredSums, this.isAllPushDown(), charSet).
setMemSizeController(session.getOtherBufferMC());
for (int i = 0; i < bucketSize; i++) {
if (terminate.get())
break;
RowDataComparator tmpComparator = new RowDataComparator(this.localResultFps, this.groupBys,
this.isAllPushDown(), this.type());
GroupByBucket bucket = new GroupByBucket(queue, outQueue, pool, localResultFps.size(), tmpComparator,