Skip to content

streamingtest: leaked goroutine in TestStreamIngestionFrontierProcessor #68795

@knz

Description

@knz

Found in e.g. https://teamcity.cockroachdb.com/buildConfiguration/Cockroach_UnitTests/3292638?expandedTest=build%3A%28id%3A3292630%29%2Cid%3A131788

stream_ingestion_frontier_processor_test.go:242: Leaked goroutine: goroutine 5777 [chan send]:
github.com/cockroachdb/cockroach/pkg/ccl/streamingccl/streamingest.(*mockStreamClient).ConsumePartition.func1(0xc0039e41e0, 0xc0039e4240, 0xc0051015e0, 0x1, 0x1, 0x5938ab0, 0xc00167c780, 0xc00722ede0, 0x44dc462, 0x12)
  /go/src/github.com/cockroachdb/cockroach/pkg/ccl/streamingccl/streamingest/stream_ingestion_processor_test.go:95 +0x26d
created by github.com/cockroachdb/cockroach/pkg/ccl/streamingccl/streamingest.(*mockStreamClient).ConsumePartition
  /go/src/github.com/cockroachdb/cockroach/pkg/ccl/streamingccl/streamingest/stream_ingestion_processor_test.go:87 +0x15c

cc @pbardea for triage

Metadata

Metadata

Assignees

Labels

A-disaster-recoveryC-bugCode not up to spec/doc, specs & docs deemed correct. Solution expected to change code/behavior.C-test-failureBroken test (automatically or manually discovered).T-disaster-recoveryskipped-test

Type

No type

Projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions