Open
Description
This test seems to be flaky (CI run)
--- FAIL: TestConcurrentFetchers (2.11s)
--- FAIL: TestConcurrentFetchers/update_concurrency_with_continuous_production (10.00s)
logging.go:33: level info component kafka_client msg immediate metadata update triggered why from user ForceMetadataRefresh
logging.go:33: level info component kafka_client msg immediate metadata update triggered why forced load because we are producing to a topic for the first time
logging.go:33: level info component kafka_client msg producing to a new topic for the first time, fetching metadata to learn its partitions topic test-topic
logging.go:33: level info component kafka_client msg done waiting for metadata for new topic topic test-topic
logging.go:33: level info component kafka_client msg initializing producer id
logging.go:33: level info component kafka_client msg producer id initialization success id 8363768319828142695 epoch 0
reader_test.go:2332:
Error Trace: /__w/mimir/mimir/pkg/storage/ingest/reader_test.go:2332
/__w/mimir/mimir/pkg/storage/ingest/fetcher_test.go:650
/usr/local/go/src/runtime/asm_amd64.s:1700
Error: Received unexpected error:
context canceled
Test: TestConcurrentFetchers/update_concurrency_with_continuous_production
fetcher_test.go:692:
Error Trace: /__w/mimir/mimir/pkg/storage/ingest/fetcher_test.go:692
Error: Not equal:
expected: 646
actual : 647
Test: TestConcurrentFetchers/update_concurrency_with_continuous_production
Messages: Should not fetch more records than produced
fetcher_test.go:706: Total produced: 647, Total fetched: 646
fetcher_test.go:707: Fetched with initial concurrency: 199
fetcher_test.go:708: Fetched with high concurrency: 300
fetcher_test.go:709: Fetched with low concurrency: 147
FAIL
FAIL github.com/grafana/mimir/pkg/storage/ingest 117.983s