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

chore: reduce router log verbosity (#3805) (#3960) 

* chore: reduce router log verbosity (#3805)

* fix: lint

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
pull/24376/head
Raphael Taylor-Davies 2022-03-07 11:38:51 +00:00 committed by GitHub
parent b69dfec25d
commit 7b3767628f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
write_buffer/src/kafka/aggregator.rs
View File

@ -4,7 +4,7 @@ use data_types::sequence::Sequence;
use dml::{DmlMeta, DmlOperation, DmlWrite};
use hashbrown::{hash_map::Entry, HashMap};
use mutable_batch::MutableBatch;
use observability_deps::tracing::{error, info, warn};
use observability_deps::tracing::{debug, error, warn};
use rskafka::{
client::producer::aggregator::{self, Aggregator, StatusDeaggregator, TryPush},
record::Record,
@ -402,7 +402,7 @@ impl Aggregator for DmlAggregator {
"missing records following flush"
);
info!(
debug!(
db_name = %self.database_name,
sequencer_id = self.sequencer_id,
records = state.tag_to_record.len(),
@ -514,7 +514,6 @@ impl StatusDeaggregator for Deaggregator {
"tag {} out of range (database_name: {}, tag_to_record: {:?}, offsets: {:?})",
tag.0, self.database_name, self.tag_to_record, input
);
// TODO: Temporary non-fatal assertion to reduce log spam (#3805)
return Err("internal aggregator error: invalid tag".into());
}