diff --git a/kernel/src/scan/mod.rs b/kernel/src/scan/mod.rs index 33ccaf4ac..b4d9c59c1 100644 --- a/kernel/src/scan/mod.rs +++ b/kernel/src/scan/mod.rs @@ -625,12 +625,8 @@ mod tests { ); } - #[test] + #[test_log::test] fn test_scan_data() { - use tracing_subscriber::EnvFilter; - tracing_subscriber::fmt() - .with_env_filter(EnvFilter::from_default_env()) - .init(); let path = std::fs::canonicalize(PathBuf::from("./tests/data/table-without-dv-small/")).unwrap(); let url = url::Url::from_directory_path(path).unwrap(); diff --git a/kernel/src/snapshot.rs b/kernel/src/snapshot.rs index 7fa55ce3f..5a02bcefb 100644 --- a/kernel/src/snapshot.rs +++ b/kernel/src/snapshot.rs @@ -76,7 +76,7 @@ impl LogSegment { use Expression as Expr; let filter = Some(Expr::or( Expr::not(Expr::is_null(Expr::column("metaData.id"))), - Expr::not(Expr::is_null(Expr::column("protocol.min_reader_version"))), + Expr::not(Expr::is_null(Expr::column("protocol.minReaderVersion"))), )); // read the same protocol and metadata schema for both commits and checkpoints let data_batches = self.replay(engine, schema.clone(), schema, filter)?;