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

chore: temporarily turn off cold compaction to investigate an oom (#5696) 

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
pull/24376/head
Nga Tran 2022-09-20 10:17:22 -04:00 committed by GitHub
parent fced536ebd
commit 578ce1854d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
compactor/src/cold.rs
View File

@ -13,6 +13,7 @@ use snafu::Snafu;
use std::sync::Arc;
/// Cold compaction. Returns the number of compacted partitions.
#[allow(dead_code)]
pub async fn compact(compactor: Arc<Compactor>) -> usize {
let compaction_type = "cold";
// Select cold partition candidates

8
compactor/src/handler.rs
View File

@ -1,6 +1,6 @@
//! Compactor handler
use crate::{cold, compact::Compactor, hot};
use crate::{compact::Compactor, hot};
use async_trait::async_trait;
use futures::{
future::{BoxFuture, Shared},
@ -162,8 +162,10 @@ pub async fn run_compactor_once(compactor: Arc<Compactor>) {
break;
}
}
debug!("start cold cycle");
compacted_partitions += cold::compact(Arc::clone(&compactor)).await;
// temporarily turn off cold compactor to see if the OOM in compactor 0 goes away
// See https://github.com/influxdata/conductor/issues/1167#issuecomment-1252391315 for the investigation steps
// debug!("start cold cycle");
// compacted_partitions += cold::compact(Arc::clone(&compactor)).await;
if compacted_partitions == 0 {
// sleep for a second to avoid a busy loop when the catalog is polled