diff --git a/server/src/db.rs b/server/src/db.rs index 21b7c725a9..49962d7f26 100644 --- a/server/src/db.rs +++ b/server/src/db.rs @@ -1460,7 +1460,7 @@ mod tests { // verify chunk size updated (chunk moved from closing to moving to moved) catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "mutable_buffer", 0).unwrap(); - catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1630).unwrap(); + catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1616).unwrap(); db.write_chunk_to_object_store("1970-01-01T00", "cpu", 0, &Default::default()) .await @@ -1480,7 +1480,7 @@ mod tests { .unwrap(); let expected_parquet_size = 759; - catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1630).unwrap(); + catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1616).unwrap(); // now also in OS catalog_chunk_size_bytes_metric_eq( &test_db.metric_registry, @@ -1650,7 +1650,7 @@ mod tests { .unwrap(); // verify chunk size updated (chunk moved from moved to writing to written) - catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1630).unwrap(); + catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1616).unwrap(); // drop, the chunk from the read buffer db.drop_chunk(partition_key, "cpu", mb_chunk.id()).unwrap(); @@ -1660,7 +1660,7 @@ mod tests { ); // verify size is reported until chunk dropped - catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1630).unwrap(); + catalog_chunk_size_bytes_metric_eq(&test_db.metric_registry, "read_buffer", 1616).unwrap(); std::mem::drop(rb_chunk); // verify chunk size updated (chunk dropped from moved state) @@ -1733,7 +1733,7 @@ mod tests { ("svr_id", "1"), ]) .histogram() - .sample_sum_eq(3231.0) + .sample_sum_eq(3189.0) .unwrap(); let rb = collect_read_filter(&rb_chunk).await; @@ -1835,7 +1835,7 @@ mod tests { ("svr_id", "10"), ]) .histogram() - .sample_sum_eq(2389.0) + .sample_sum_eq(2375.0) .unwrap(); // it should be the same chunk! @@ -1943,7 +1943,7 @@ mod tests { ("svr_id", "10"), ]) .histogram() - .sample_sum_eq(2389.0) + .sample_sum_eq(2375.0) .unwrap(); // Unload RB chunk but keep it in OS @@ -2343,7 +2343,7 @@ mod tests { Arc::from("cpu"), 0, ChunkStorage::ReadBufferAndObjectStore, - 2380, // size of RB and OS chunks + 2373, // size of RB and OS chunks 1, ), ChunkSummary::new_without_timestamps( @@ -2394,7 +2394,7 @@ mod tests { .memory() .read_buffer() .get_total(), - 1621 + 1614 ); assert_eq!( db.catalog.state().metrics().memory().parquet().get_total(),