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 (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/2456978441/?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
(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 221 to 223 in 89dd2d1

	func (m *memColumn) Int32() Int32s {
	return m.col.(Int32s)
	}

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

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

Lines 9929 to 9931 in 89dd2d1

	probeKeys := probeVec.Int32()
	buildKeys := buildVec.Int32()
	if probeSel != nil {

in pkg/sql/colexec.(*hashTable).checkColForDistinctTuples

cockroach/pkg/sql/colexec/hashtable.go

Lines 487 to 489 in 89dd2d1

	ht.checkColForDistinctTuples(probeVec, buildVec, nToCheck, probeSel)
	}

in pkg/sql/colexec.(*hashTable).checkColsForDistinctTuples

cockroach/pkg/sql/colexec/hashtable.go

Lines 594 to 596 in 89dd2d1

	}
	ht.checkColsForDistinctTuples(probeVecs, nToCheck, probeSel)
	nDiffers := uint64(0)

in pkg/sql/colexec.(*hashTable).checkBuildForDistinct

cockroach/pkg/sql/colexec/hashtable.go

Lines 427 to 429 in 89dd2d1

	// array is non-empty.
	nToCheck = duplicatesChecker(keyCols, nToCheck, sel)
	ht.findNext(next, nToCheck)

in pkg/sql/colexec.(*hashTable).findBuckets

cockroach/pkg/sql/colexec/hashtable.go

Lines 442 to 444 in 89dd2d1

	) {
	ht.findBuckets(batch, keyCols, first, next, duplicatesChecker)
	ht.updateSel(batch)

in pkg/sql/colexec.(*hashTable).removeDuplicates

cockroach/pkg/sql/colexec/hashtable.go

Lines 355 to 357 in 89dd2d1

	if ht.vals.Length() > 0 {
	ht.removeDuplicates(batch, ht.keys, ht.buildScratch.first, ht.buildScratch.next, ht.checkBuildForDistinct)
	}

in pkg/sql/colexec.(*hashTable).build

cockroach/pkg/sql/colexec/unordered_distinct.go

Lines 83 to 85 in 89dd2d1

	op.buildFinished = true
	op.ht.build(ctx, op.input)

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

cockroach/pkg/sql/colexec/materializer.go

Lines 221 to 223 in 89dd2d1

	// Get a fresh batch.
	m.batch = m.input.Next(m.Ctx)
	if m.batch.Length() == 0 {

in pkg/sql/colexec.(*Materializer).next

cockroach/pkg/sql/colexec/materializer.go

Lines 246 to 248 in 89dd2d1

	func (m *Materializer) nextAdapter() {
	m.outputRow = m.next()
	}

in pkg/sql/colexec.(*Materializer).nextAdapter

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/materializer.go

Lines 252 to 254 in 89dd2d1

	for m.State == execinfra.StateRunning {
	if err := colexecerror.CatchVectorizedRuntimeError(m.nextAdapter); err != nil {
	m.MoveToDraining(err)

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

cockroach/pkg/sql/execinfra/base.go

Lines 169 to 171 in 89dd2d1

	for {
	row, meta := src.Next()
	// Emit the row; stop if no more rows are needed.

in pkg/sql/execinfra.Run

cockroach/pkg/sql/execinfra/processorsbase.go

Lines 774 to 776 in 89dd2d1

	ctx = pb.self.Start(ctx)
	Run(ctx, pb.self, pb.Out.output)
	}

in pkg/sql/execinfra.(*ProcessorBase).Run

cockroach/pkg/sql/flowinfra/flow.go

Lines 391 to 393 in 89dd2d1

	}
	headProc.Run(ctx)
	return nil

in pkg/sql/flowinfra.(*FlowBase).Run

cockroach/pkg/sql/distsql_running.go

Lines 421 to 423 in 89dd2d1

	// TODO(radu): this should go through the flow scheduler.
	if err := flow.Run(ctx, func() {}); err != nil {
	log.Fatalf(ctx, "unexpected error from syncFlow.Start(): %v\n"+

in pkg/sql.(*DistSQLPlanner).Run

cockroach/pkg/sql/distsql_running.go

Lines 1001 to 1003 in 89dd2d1

	recv.expectedRowsRead = int64(physPlan.TotalEstimatedScannedRows)
	return dsp.Run(planCtx, txn, physPlan, recv, evalCtx, nil /* finishedSetupFn */)
	}

in pkg/sql.(*DistSQLPlanner).PlanAndRun

cockroach/pkg/sql/conn_executor_exec.go

Lines 1000 to 1002 in 89dd2d1

	// the planner whether or not to plan remote table readers.
	cleanup := ex.server.cfg.DistSQLPlanner.PlanAndRun(
	ctx, evalCtx, planCtx, planner.txn, planner.curPlan.main, recv,

in pkg/sql.(*connExecutor).execWithDistSQLEngine

cockroach/pkg/sql/conn_executor_exec.go

Lines 871 to 873 in 89dd2d1

	ex.sessionTracing.TraceExecStart(ctx, "distributed")
	stats, err := ex.execWithDistSQLEngine(
	ctx, planner, stmt.AST.StatementType(), res, distributePlan.WillDistribute(), progAtomic,

in pkg/sql.(*connExecutor).dispatchToExecutionEngine

cockroach/pkg/sql/conn_executor_exec.go

Lines 638 to 640 in 89dd2d1

	p.autoCommit = os.ImplicitTxn.Get() && !ex.server.cfg.TestingKnobs.DisableAutoCommit
	if err := ex.dispatchToExecutionEngine(ctx, p, res); err != nil {
	return nil, nil, err

in pkg/sql.(*connExecutor).execStmtInOpenState

cockroach/pkg/sql/conn_executor_exec.go

Lines 113 to 115 in 89dd2d1

	} else {
	ev, payload, err = ex.execStmtInOpenState(ctx, stmt, res, pinfo)
	}

in pkg/sql.(*connExecutor).execStmt

cockroach/pkg/sql/conn_executor_exec.go

Lines 202 to 204 in 89dd2d1

	if !portal.exhausted {
	ev, payload, err = ex.execStmt(stmtCtx, curStmt, stmtRes, pinfo)
	// Portal suspension is supported via a "side" state machine

in pkg/sql.(*connExecutor).execPortal

cockroach/pkg/sql/conn_executor.go

Lines 1532 to 1534 in 89dd2d1

	res = stmtRes
	ev, payload, err = ex.execPortal(ctx, portal, portalName, stmtRes, pinfo)
	return err

in pkg/sql.(*connExecutor).execCmd.func2

cockroach/pkg/sql/conn_executor.go

Lines 1534 to 1536 in 89dd2d1

	return err
	}()
	// Note: we write to ex.statsCollector.phaseTimes, instead of ex.phaseTimes,

in pkg/sql.(*connExecutor).execCmd

cockroach/pkg/sql/conn_executor.go

Lines 1390 to 1392 in 89dd2d1

	var err error
	if err = ex.execCmd(ex.Ctx()); err != nil {
	if errors.IsAny(err, io.EOF, errDrainingComplete) {

in pkg/sql.(*connExecutor).run

cockroach/pkg/sql/conn_executor.go

Lines 507 to 509 in 89dd2d1

	}()
	return h.ex.run(ctx, s.pool, reserved, cancel)
	}

in pkg/sql.(*Server).ServeConn

cockroach/pkg/sql/pgwire/conn.go

Lines 625 to 627 in 89dd2d1

	reservedOwned = false // We're about to pass ownership away.
	retErr = sqlServer.ServeConn(ctx, connHandler, reserved, cancelConn)
	}()

in pkg/sql/pgwire.(*conn).processCommandsAsync.func1
/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).Int32 at line 222
pkg/sql/colexec/hashtable_distinct.eg.go in pkg/sql/colexec.(*hashTable).checkColForDistinctTuples at line 9930
pkg/sql/colexec/hashtable.go in pkg/sql/colexec.(*hashTable).checkColsForDistinctTuples at line 488
pkg/sql/colexec/hashtable.go in pkg/sql/colexec.(*hashTable).checkBuildForDistinct at line 595
pkg/sql/colexec/hashtable.go in pkg/sql/colexec.(*hashTable).findBuckets at line 428
pkg/sql/colexec/hashtable.go in pkg/sql/colexec.(*hashTable).removeDuplicates at line 443
pkg/sql/colexec/hashtable.go in pkg/sql/colexec.(*hashTable).build at line 356
pkg/sql/colexec/unordered_distinct.go in pkg/sql/colexec.(*unorderedDistinct).Next at line 84
pkg/sql/colexec/materializer.go in pkg/sql/colexec.(*Materializer).next at line 222
pkg/sql/colexec/materializer.go in pkg/sql/colexec.(*Materializer).nextAdapter at line 247
pkg/sql/colexecbase/colexecerror/error.go in pkg/sql/colexecbase/colexecerror.CatchVectorizedRuntimeError at line 93
pkg/sql/colexec/materializer.go in pkg/sql/colexec.(*Materializer).Next at line 253
pkg/sql/execinfra/base.go in pkg/sql/execinfra.Run at line 170
pkg/sql/execinfra/processorsbase.go in pkg/sql/execinfra.(*ProcessorBase).Run at line 775
pkg/sql/flowinfra/flow.go in pkg/sql/flowinfra.(*FlowBase).Run at line 392
pkg/sql/distsql_running.go in pkg/sql.(*DistSQLPlanner).Run at line 422
pkg/sql/distsql_running.go in pkg/sql.(*DistSQLPlanner).PlanAndRun at line 1002
pkg/sql/conn_executor_exec.go in pkg/sql.(*connExecutor).execWithDistSQLEngine at line 1001
pkg/sql/conn_executor_exec.go in pkg/sql.(*connExecutor).dispatchToExecutionEngine at line 872
pkg/sql/conn_executor_exec.go in pkg/sql.(*connExecutor).execStmtInOpenState at line 639
pkg/sql/conn_executor_exec.go in pkg/sql.(*connExecutor).execStmt at line 114
pkg/sql/conn_executor_exec.go in pkg/sql.(*connExecutor).execPortal at line 203
pkg/sql/conn_executor.go in pkg/sql.(*connExecutor).execCmd.func2 at line 1533
pkg/sql/conn_executor.go in pkg/sql.(*connExecutor).execCmd at line 1535
pkg/sql/conn_executor.go in pkg/sql.(*connExecutor).run at line 1391
pkg/sql/conn_executor.go in pkg/sql.(*Server).ServeConn at line 508
pkg/sql/pgwire/conn.go in pkg/sql/pgwire.(*conn).processCommandsAsync.func1 at line 626
/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	start-single-node
Go Version	``
# of CPUs
# of Goroutines

[yuzefovich]

Likely a dup of #59148