diff --git a/src/flow/src/compute/render/reduce.rs b/src/flow/src/compute/render/reduce.rs index a539da36e742..786f69c247fe 100644 --- a/src/flow/src/compute/render/reduce.rs +++ b/src/flow/src/compute/render/reduce.rs @@ -1447,7 +1447,7 @@ mod test { let now = *now_inner.borrow(); let data = recv.take_inner(); let res = data.into_iter().flat_map(|v| v.into_iter()).collect_vec(); - dbg!(&res); + if let Some(expected) = expected.get(&now) { let batch = expected.iter().map(|v| Value::from(*v)).collect_vec(); let batch = Batch::try_from_rows(vec![batch.into()]).unwrap(); diff --git a/src/flow/src/lib.rs b/src/flow/src/lib.rs index 738ed524ba04..12aa7f6385fa 100644 --- a/src/flow/src/lib.rs +++ b/src/flow/src/lib.rs @@ -21,6 +21,10 @@ #![allow(dead_code)] #![warn(clippy::missing_docs_in_private_items)] #![warn(clippy::too_many_lines)] + +// TODO(discord9): enable this lint to handle out of bound access +// #![cfg_attr(not(test), warn(clippy::indexing_slicing))] + // allow unused for now because it should be use later mod adapter; mod compute;