diff --git a/pkg/sql/colexec2/group/group.go b/pkg/sql/colexec2/group/group.go index fccfa525f9444d6cf1ddcb8c3282c91e65fa759d..cbfc76a78e1d6424e1f5cfeb1763df279edcdc64 100644 --- a/pkg/sql/colexec2/group/group.go +++ b/pkg/sql/colexec2/group/group.go @@ -89,7 +89,7 @@ func (ctr *Container) process(ap *Argument, proc *process.Process) (bool, error) vector.Clean(ctr.aggVecs[j].vec, proc.Mp) } } - return false, nil + return false, err } ctr.aggVecs[i].vec = vec ctr.aggVecs[i].needFree = true