diff --git a/pkg/sql/colexec/aggexec/concat.go b/pkg/sql/colexec/aggexec/concat.go index f0e82e6a694f6..083d37ee41c80 100644 --- a/pkg/sql/colexec/aggexec/concat.go +++ b/pkg/sql/colexec/aggexec/concat.go @@ -23,10 +23,6 @@ import ( "math" ) -const ( - groupConcatMaxLen = 1024 -) - // group_concat is a special string aggregation function. type groupConcatExec struct { multiAggInfo @@ -116,9 +112,6 @@ func (exec *groupConcatExec) Fill(groupIndex int, row int, vectors []*vector.Vec exec.ret.groupToSet = groupIndex exec.ret.setGroupNotEmpty(groupIndex) r := exec.ret.aggGet() - if len(r) > groupConcatMaxLen { - return nil - } if len(r) > 0 { r = append(r, exec.separator...) } @@ -172,7 +165,7 @@ func (exec *groupConcatExec) merge(other *groupConcatExec, idx1, idx2 int) error v1 := exec.ret.aggGet() v2 := other.ret.aggGet() - if len(v2) == 0 || len(v1) > groupConcatMaxLen { + if len(v2) == 0 { return nil } if len(v1) > 0 && len(v2) > 0 {