commit
0aa81bf405
|
@ -1,6 +1,7 @@
|
||||||
//! This module contains structs that describe the metadata for a partition
|
//! This module contains structs that describe the metadata for a partition
|
||||||
//! including schema, summary statistics, and file locations in storage.
|
//! including schema, summary statistics, and file locations in storage.
|
||||||
|
|
||||||
|
use observability_deps::tracing::warn;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use std::{
|
use std::{
|
||||||
borrow::{Borrow, Cow},
|
borrow::{Borrow, Cow},
|
||||||
|
@ -106,15 +107,12 @@ impl TableSummary {
|
||||||
|
|
||||||
// Validate that the counts are consistent across columns
|
// Validate that the counts are consistent across columns
|
||||||
for c in &self.columns {
|
for c in &self.columns {
|
||||||
assert_eq!(
|
// Restore to assert when https://github.com/influxdata/influxdb_iox/issues/2124 is fixed
|
||||||
c.total_count(),
|
if c.total_count() != count {
|
||||||
count,
|
warn!(table_name=%self.name, column_name=%c.name,
|
||||||
"Mismatch counts in table {} column {}, expected {} got {}",
|
column_count=c.total_count(), previous_count=count,
|
||||||
self.name,
|
"Mismatch in statistics count, see #2124");
|
||||||
c.name,
|
}
|
||||||
count,
|
|
||||||
c.total_count()
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
count
|
count
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue