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

test: Clarify descriptions for the remaining assertion 

The assertion remaining in this test is now important because of having
multiple shards and showing which partition per shard is chosen.
pull/24376/head
Carol (Nichols || Goulding) 2022-09-19 11:55:24 -04:00
parent 7c7b058276
commit f0bf3bd21c
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
compactor/src/hot.rs
View File

@ -517,31 +517,28 @@ mod tests {
// This test is an integration test that covers the priority of the candidate selection
// algorithm when there are many files of different kinds across many partitions.
// partition1 has a deleted L0
// partition1 has a deleted L0, isn't returned
let builder = TestParquetFileBuilder::default().with_to_delete(true);
let _pf1 = partition1.create_parquet_file_catalog_record(builder).await;
// partition2 has a non-L0 file
// partition2 has a non-L0 file, isn't returned
let builder = TestParquetFileBuilder::default()
.with_compaction_level(CompactionLevel::FileNonOverlapped);
let _pf2 = partition2.create_parquet_file_catalog_record(builder).await;
// partition2 has an old (more than 8 hours ago) non-deleted level 0 file
// partition2 has an old (more than 8 hours ago) non-deleted level 0 file, isn't returned
let builder = TestParquetFileBuilder::default().with_creation_time(time_38_hour_ago);
let _pf3 = partition2.create_parquet_file_catalog_record(builder).await;
// partition4 has a new write 5 hours ago
// partition4 has a new write 5 hours ago, isn't returned
let builder = TestParquetFileBuilder::default().with_creation_time(time_five_hour_ago);
let _pf4 = partition4.create_parquet_file_catalog_record(builder).await;
// partition3 has a new write 3 minutes ago
// partition3 has a new write 3 minutes ago, is returned
let builder = TestParquetFileBuilder::default().with_creation_time(time_three_minutes_ago);
let _pf5 = partition3.create_parquet_file_catalog_record(builder).await;
// --------------------------------------
// Case 6: has partition candidates for 2 shards
//
// The another_shard now has non-deleted level-0 file ingested 5 hours ago
// The another_shard now has non-deleted level-0 file ingested 5 hours ago, is returned
let builder = TestParquetFileBuilder::default().with_creation_time(time_five_hour_ago);
let _pf6 = another_partition
.create_parquet_file_catalog_record(builder)