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

docs: reference WAL segement ref-counting ticket 

Reference the WAL ref-counting ticket in the WAL rotation task.
pull/24376/head
Dom Dwyer 2023-01-11 16:21:48 +01:00
parent bbd41228bc
commit c01d5566b9
No known key found for this signature in database
GPG Key ID: E4C40DBD9157879A
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingester2/src/persist/handle.rs
View File

@ -119,7 +119,7 @@ use crate::{
/// crate::ingest_state::IngestStateError::PersistSaturated /// crate::ingest_state::IngestStateError::PersistSaturated
#[derive(Debug)] #[derive(Debug)]
pub(crate) struct PersistHandle { pub(crate) struct PersistHandle {
/// THe state/dependencies shared across all worker tasks. /// The state/dependencies shared across all worker tasks.
worker_state: Arc<SharedWorkerState>, worker_state: Arc<SharedWorkerState>,
/// Task handles for the worker tasks, aborted on drop of all /// Task handles for the worker tasks, aborted on drop of all

2
ingester2/src/wal/rotate_task.rs
View File

@ -68,6 +68,8 @@ pub(crate) async fn periodic_rotation<T, P>(
// special code path between "hot partition persist" and "wal rotation // special code path between "hot partition persist" and "wal rotation
// persist" - it all works the same way! // persist" - it all works the same way!
// //
// https://github.com/influxdata/influxdb_iox/issues/6566
//
// TODO: this properly as described above. // TODO: this properly as described above.
tokio::time::sleep(Duration::from_secs(5)).await; tokio::time::sleep(Duration::from_secs(5)).await;