Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: more verbose shard reset logs 

Adds a little more context to the "shard reset" logs.
pull/24376/head
Dom Dwyer 2022-10-19 11:47:03 +02:00
parent 40f1937e63
commit 0c0a38c484
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ingester/src/stream_handler/handler.rs
View File

@ -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