From 0c0a38c4844064057faee77b764a8afaedc90d23 Mon Sep 17 00:00:00 2001 From: Dom Dwyer Date: Wed, 19 Oct 2022 11:47:03 +0200 Subject: [PATCH] refactor: more verbose shard reset logs Adds a little more context to the "shard reset" logs. --- ingester/src/stream_handler/handler.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/ingester/src/stream_handler/handler.rs b/ingester/src/stream_handler/handler.rs index 1b674fd2ea..3f32b20bcd 100644 --- a/ingester/src/stream_handler/handler.rs +++ b/ingester/src/stream_handler/handler.rs @@ -279,7 +279,8 @@ where shard_index=%self.shard_index, shard_id=%self.shard_id, potential_data_loss=true, - "reset stream" + "unable to read from desired sequence number offset \ + - reset stream to oldest available data" ); self.shard_reset_count.inc(1); sequence_number_before_reset = Some(self.current_sequence_number); @@ -293,7 +294,8 @@ where shard_index=%self.shard_index, shard_id=%self.shard_id, potential_data_loss=true, - "unable to read from desired sequence number offset" + "unable to read from desired sequence number offset \ + - aborting ingest due to configuration" ); self.shard_unknown_sequence_number_count.inc(1); None