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

Merge branch 'main' into tzlogfmts

pull/24376/head
Edd Robinson 2021-10-20 13:42:12 +01:00 committed by GitHub
parent ae82236bc4 fe5eea37da
commit 596d8aa5de
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lifecycle/src/policy.rs
View File

@ -84,7 +84,7 @@ where
) { ) {
let buffer_size = self.db.buffer_size(); let buffer_size = self.db.buffer_size();
if buffer_size < soft_limit { if buffer_size < soft_limit {
debug!(%db_name, buffer_size, %soft_limit, "memory use under soft limit"); trace!(%db_name, buffer_size, %soft_limit, "memory use under soft limit");
return; return;
} }
@ -269,7 +269,7 @@ where
_ => unreachable!("this chunk should be have filtered out already"), _ => unreachable!("this chunk should be have filtered out already"),
} }
let has_added_to_compact = to_compact.len() > to_compact_len_before; let has_added_to_compact = to_compact.len() > to_compact_len_before;
debug!(db_name = %self.db.name(), trace!(db_name = %self.db.name(),
%partition, %partition,
?has_added_to_compact, ?has_added_to_compact,
chunk_storage = ?storage, chunk_storage = ?storage,
@ -355,7 +355,7 @@ where
.unwrap_or_default(); .unwrap_or_default();
let persistable_row_count = partition.persistable_row_count(); let persistable_row_count = partition.persistable_row_count();
debug!(%db_name, %partition, trace!(%db_name, %partition,
partition_persist_row_count=persistable_row_count, partition_persist_row_count=persistable_row_count,
rules_persist_row_count=%rules.persist_row_threshold.get(), rules_persist_row_count=%rules.persist_row_threshold.get(),
partition_persistable_age_seconds=persistable_age_seconds, partition_persistable_age_seconds=persistable_age_seconds,
@ -367,7 +367,7 @@ where
} else if persistable_age_seconds >= rules.persist_age_threshold_seconds.get() as u64 { } else if persistable_age_seconds >= rules.persist_age_threshold_seconds.get() as u64 {
info!(%db_name, %partition, persistable_age_seconds, "persisting partition as exceeds age threshold"); info!(%db_name, %partition, persistable_age_seconds, "persisting partition as exceeds age threshold");
} else { } else {
debug!(%db_name, %partition, persistable_row_count, "partition not eligible for persist"); trace!(%db_name, %partition, persistable_row_count, "partition not eligible for persist");
return false; return false;
} }