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

fix: collect checkpoint data from all tables

pull/24376/head
Marco Neumann 2021-07-21 14:41:58 +02:00
parent ffe6e62aee
commit ec866de193
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
server/src/db/lifecycle/write.rs
View File

@ -219,17 +219,18 @@ fn collect_checkpoints(
// calculate checkpoint
let mut checkpoint_builder = PersistCheckpointBuilder::new(partition_checkpoint);
// collect checkpoints of all other partitions
if let Ok(table) = catalog.table(table_name) {
for partition in table.partitions() {
let partition = partition.read();
if partition.key() == partition_key.as_ref() {
continue;
}
// collect checkpoints of all other partitions of all tables
for partition in catalog.partitions() {
let partition = partition.read();
if (partition.table_name() == table_name.as_ref())
&& (partition.key() == partition_key.as_ref())
{
// same partition as the one that we're currently persisting => skip
continue;
}
if let Some(partition_checkpoint) = partition.partition_checkpoint() {
checkpoint_builder.register_other_partition(&partition_checkpoint);
}
if let Some(partition_checkpoint) = partition.partition_checkpoint() {
checkpoint_builder.register_other_partition(&partition_checkpoint);
}
}