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

test: fix tests

pull/24376/head
Edd Robinson 2021-06-03 12:06:42 +01:00
parent 9a45c0d05b
commit 65bfa4dd10
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
server/src/db.rs
View File

@ -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(),