sql/stmtdiagnostics: TestDiagnosticsRequest failed

[cockroach-teamcity]

sql/stmtdiagnostics.TestDiagnosticsRequest failed with artifacts on master @ c3d71ac887844bef174abb6dab2a4e1ce9270ab7:

../colmem/allocator.go:592 colmem.(*SetAccountingHelper).ResetMaybeReallocate { ) (newBatch coldata.Batch, reallocated bool) { }
../colfetcher/cfetcher.go:347 colfetcher.(*cFetcher).resetBatch { } }
../colfetcher/cfetcher.go:1065 colfetcher.(*cFetcher).shiftState { func (rf *cFetcher) shiftState() { }
../colfetcher/index_join.go:229 colfetcher.(*ColIndexJoin).Next { batch, err := s.rf.NextBatch(s.Ctx) }
../colexec/invariants_checker.go:94 colexec.(*invariantsChecker).Next { b := i.Input.Next() }
../colexec/colexecutils/cancel_checker.go:58 colexecutils.(*CancelChecker).Next { c.CheckEveryCall() }
../colexec/colexecutils/operator.go:137 colexecutils.(*vectorTypeEnforcer).Next { b := e.Input.Next() }
../colexec/colexecbase/const.eg.go:479 colexecbase.constTimestampOp.Next { batch := c.Input.Next() }
../colexec/invariants_checker.go:94 colexec.(*invariantsChecker).Next { b := i.Input.Next() }
../colexec/materializer.go:265 colexec.(*Materializer).next { // Get a fresh batch. }
../colexec/materializer.go:290 colexec.(*Materializer).nextAdapter { func (m *Materializer) nextAdapter() { }
../colexecerror/error.go:91 colexecerror.CatchVectorizedRuntimeError { operation() }
../colexec/materializer.go:296 colexec.(*Materializer).Next { for m.State == execinfra.StateRunning { }
../row_source_to_plan_node.go:75 sql.(*rowSourceToPlanNode).Next { var p *execinfrapb.ProducerMetadata }
../update.go:162 sql.(*updateNode).BatchedNext { // Advance one individual row. }
../plan_batch.go:114 sql.(*serializeNode).Next { // First batch, or finished previous batch; advance one. }
../plan_node_to_row_source.go:191 sql.(*planNodeToRowSource).Next { valid, err := p.node.Next(p.params) }
../colflow/flow_coordinator.go:127 colflow.(*FlowCoordinator).next { if f.State == execinfra.StateRunning { }
../colflow/flow_coordinator.go:144 colflow.(*FlowCoordinator).nextAdapter { func (f *FlowCoordinator) nextAdapter() { }
../colexecerror/error.go:91 colexecerror.CatchVectorizedRuntimeError { operation() }
../colflow/flow_coordinator.go:149 colflow.(*FlowCoordinator).Next { func (f *FlowCoordinator) Next() (rowenc.EncDatumRow, *execinfrapb.ProducerMetadata) { }
../execinfra/base.go:187 execinfra.Run { // Emit the row; stop if no more rows are needed. }
../execinfra/processorsbase.go:733 execinfra.(*ProcessorBaseNoHelper).Run { Run(pb.Ctx, pb.self, pb.Output) }
../flowinfra/flow.go:453 flowinfra.(*FlowBase).Run { headProc.Run(ctx) }
../colflow/vectorized_flow.go:246 colflow.(*vectorizedFlow).Run { f.FlowBase.Run(ctx, doneFn) }
../distsql_running.go:566 sql.(*DistSQLPlanner).Run { // PlanAndRun. We should refactor this and get rid off ignoreClose field. }
../distsql_running.go:1400 sql.(*DistSQLPlanner).PlanAndRun { recv.expectedRowsRead = int64(physPlan.TotalEstimatedScannedRows) }
../conn_executor_exec.go:1411 sql.(*connExecutor).execWithDistSQLEngine { // need to have access to the main query tree. }
../conn_executor_exec.go:1109 sql.(*connExecutor).dispatchToExecutionEngine { // plan has not been closed earlier. }
../conn_executor_exec.go:720 sql.(*connExecutor).execStmtInOpenState {  }
../conn_executor_exec.go:134 sql.(*connExecutor).execStmt { } else { }
../conn_executor.go:1751 sql.(*connExecutor).execCmd.func1 {  }
../conn_executor.go:1761 sql.(*connExecutor).execCmd { ex.statsCollector.PhaseTimes().SetSessionPhaseTime(sessionphase.SessionQueryServiced, timeutil.Now()) }
../conn_executor.go:1675 sql.(*connExecutor).run { var err error }
../internal.go:204 sql.(*InternalExecutor).initConnEx.func1 { go func() { }

goroutine 117944 lock 0xc00287d220
../../kv/kvclient/kvstreamer/streamer.go:758 kvstreamer.(*workerCoordinator).issueRequestsForAsyncProcessing { w.s.budget.mu.Lock() } <<<<<
../../kv/kvclient/kvstreamer/streamer.go:757 kvstreamer.(*workerCoordinator).issueRequestsForAsyncProcessing { }() }
../../kv/kvclient/kvstreamer/streamer.go:713 kvstreamer.(*workerCoordinator).mainLoop { err := w.issueRequestsForAsyncProcessing(ctx, requestsToServe, avgResponseSize) }
../../util/stop/stopper.go:488 stop.(*Stopper).RunAsyncTaskEx.func2 { f(ctx) }





ERROR: exit status 2

1 runs completed, 1 failures, over 2s
context canceled

Help

See also: How To Investigate a Go Test Failure (internal)
Parameters in this failure:

• TAGS=deadlock

• GOFLAGS=-parallel=4

/cc @cockroachdb/sql-queries

This test on roachdash | Improve this report!