sentry: error.go:90: unexpected error from the vectorized engine: × -- *barriers.barrierError *errutil.withPrefix: unexpected error from the vectorized engine (1) error.go:90: *withstack.withStack (top exception) *assert.withAssertionFailure *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError *colexecerror.notInternalError (check the extra data payloads)

[cockroach-teamcity]

This issue was autofiled by Sentry. It represents a crash or reported error on a live cluster with telemetry enabled.

Sentry link: https://sentry.io/organizations/cockroach-labs/issues/2186892097/?referrer=webhooks_plugin

Panic message:

error.go:90: unexpected error from the vectorized engine: ×
--
*barriers.barrierError
*errutil.withPrefix: unexpected error from the vectorized engine (1)
error.go:90: *withstack.withStack (top exception)
*assert.withAssertionFailure
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
*colexecerror.notInternalError
(check the extra data payloads)

Stacktrace (expand for inline code snippets):

cockroach/pkg/sql/colexecbase/colexecerror/error.go

Lines 89 to 91 in 89dd2d1

	// unexpected.
	retErr = errors.NewAssertionErrorWithWrappedErrf(err, "unexpected error from the vectorized engine")
	}

in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError.func1
/usr/local/go/src/runtime/panic.go#L678-L680 in runtime.gopanic
/usr/local/go/src/runtime/iface.go#L254-L256 in runtime.panicdottypeE

cockroach/pkg/col/coldata/vec.go

Lines 225 to 227 in 89dd2d1

	func (m *memColumn) Int64() Int64s {
	return m.col.(Int64s)
	}

in pkg/col/coldata.(*memColumn).Int64

cockroach/pkg/sql/colexec/ordered_synchronizer.eg.go

Lines 186 to 188 in 89dd2d1

	default:
	srcCol := vec.Int64()
	outCol := o.outInt64Cols[o.outColsMap[i]]

in pkg/sql/colexec.(*OrderedSynchronizer).Next.func1

cockroach/pkg/sql/colmem/allocator.go

Lines 285 to 287 in 89dd2d1

	// caused by this approach is ok.
	operation()
	after := getVecsMemoryFootprint(destVecs)

in pkg/sql/colmem.(*Allocator).PerformOperation

cockroach/pkg/sql/colexec/ordered_synchronizer.eg.go

Lines 125 to 127 in 89dd2d1

	outputIdx := 0
	o.allocator.PerformOperation(o.output.ColVecs(), func() {
	for outputIdx < o.output.Capacity() {

in pkg/sql/colexec.(*OrderedSynchronizer).Next

cockroach/pkg/sql/colexec/operator.go

Lines 237 to 239 in 89dd2d1

	func (n *noopOperator) Next(ctx context.Context) coldata.Batch {
	return n.input.Next(ctx)
	}

in pkg/sql/colexec.(*noopOperator).Next

cockroach/pkg/sql/colexec/routers.go

Lines 725 to 727 in 89dd2d1

	func (r *HashRouter) processNextBatch(ctx context.Context) bool {
	b := r.input.Next(ctx)
	n := b.Length()

in pkg/sql/colexec.(*HashRouter).processNextBatch

cockroach/pkg/sql/colexec/routers.go

Lines 660 to 662 in 89dd2d1

	processNextBatch := func() {
	done = r.processNextBatch(ctx)
	}

in pkg/sql/colexec.(*HashRouter).Run.func1.1

cockroach/pkg/sql/colexecbase/colexecerror/error.go

Lines 92 to 94 in 89dd2d1

	}()
	operation()
	return retErr

in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError

cockroach/pkg/sql/colexec/routers.go

Lines 698 to 700 in 89dd2d1

	if err := colexecerror.CatchVectorizedRuntimeError(processNextBatch); err != nil {
	r.cancelOutputs(ctx, err)

in pkg/sql/colexec.(*HashRouter).Run.func1

cockroach/pkg/sql/colexecbase/colexecerror/error.go

Lines 92 to 94 in 89dd2d1

	}()
	operation()
	return retErr

in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError

cockroach/pkg/sql/colexec/routers.go

Lines 656 to 658 in 89dd2d1

	// well for more fine-grained control of error propagation.
	if err := colexecerror.CatchVectorizedRuntimeError(func() {
	r.input.Init()

in pkg/sql/colexec.(*HashRouter).Run

cockroach/pkg/sql/colflow/vectorized_flow.go

Lines 663 to 665 in 89dd2d1

	runRouter := func(ctx context.Context, _ context.CancelFunc) {
	router.Run(logtags.AddTag(ctx, "hashRouterID", strings.Join(streamIDs, ",")))
	}

in pkg/sql/colflow.(*vectorizedFlowCreator).setupRouter.func1

cockroach/pkg/sql/colflow/vectorized_flow.go

Lines 1203 to 1205 in 89dd2d1

	go func() {
	run(ctx, cancelFn)
	if wg != nil {

in pkg/sql/colflow.(*vectorizedFlowCreatorHelper).accumulateAsyncComponent.func1.1
/usr/local/go/src/runtime/asm_amd64.s#L1356-L1358 in runtime.goexit

pkg/sql/colexecbase/colexecerror/error.go in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError.func1 at line 90
/usr/local/go/src/runtime/panic.go in runtime.gopanic at line 679
/usr/local/go/src/runtime/iface.go in runtime.panicdottypeE at line 255
pkg/col/coldata/vec.go in pkg/col/coldata.(*memColumn).Int64 at line 226
pkg/sql/colexec/ordered_synchronizer.eg.go in pkg/sql/colexec.(*OrderedSynchronizer).Next.func1 at line 187
pkg/sql/colmem/allocator.go in pkg/sql/colmem.(*Allocator).PerformOperation at line 286
pkg/sql/colexec/ordered_synchronizer.eg.go in pkg/sql/colexec.(*OrderedSynchronizer).Next at line 126
pkg/sql/colexec/operator.go in pkg/sql/colexec.(*noopOperator).Next at line 238
pkg/sql/colexec/routers.go in pkg/sql/colexec.(*HashRouter).processNextBatch at line 726
pkg/sql/colexec/routers.go in pkg/sql/colexec.(*HashRouter).Run.func1.1 at line 661
pkg/sql/colexecbase/colexecerror/error.go in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError at line 93
pkg/sql/colexec/routers.go in pkg/sql/colexec.(*HashRouter).Run.func1 at line 699
pkg/sql/colexecbase/colexecerror/error.go in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError at line 93
pkg/sql/colexec/routers.go in pkg/sql/colexec.(*HashRouter).Run at line 657
pkg/sql/colflow/vectorized_flow.go in pkg/sql/colflow.(*vectorizedFlowCreator).setupRouter.func1 at line 664
pkg/sql/colflow/vectorized_flow.go in pkg/sql/colflow.(*vectorizedFlowCreatorHelper).accumulateAsyncComponent.func1.1 at line 1204
/usr/local/go/src/runtime/asm_amd64.s in runtime.goexit at line 1357

Tag	Value
Cockroach Release	v20.2.3
Cockroach SHA:	89dd2d1
Platform	linux amd64
Distribution	CCL
Environment	v20.2.3
Command	server
Go Version	``
# of CPUs
# of Goroutines

[yuzefovich]

I think it is likely a dup of #59148