diff --git a/bench-vortex/benches/datafusion_benchmark.rs b/bench-vortex/benches/datafusion_benchmark.rs
index 3e683d8544..73c3ced0e0 100644
--- a/bench-vortex/benches/datafusion_benchmark.rs
+++ b/bench-vortex/benches/datafusion_benchmark.rs
@@ -8,9 +8,8 @@ use criterion::{black_box, criterion_group, criterion_main, BenchmarkGroup, Crit
 use datafusion::common::Result as DFResult;
 use datafusion::datasource::{MemTable, TableProvider};
 use datafusion::execution::memory_pool::human_readable_size;
-use datafusion::functions_aggregate::expr_fn::sum;
 use datafusion::logical_expr::lit;
-use datafusion::prelude::{col, DataFrame, SessionContext};
+use datafusion::prelude::{col, count_distinct, DataFrame, SessionContext};
 use lazy_static::lazy_static;
 use vortex::compress::Compressor;
 use vortex::encoding::EncodingRef;
@@ -87,7 +86,7 @@ fn filter_agg_query(df: DataFrame) -> DFResult<DataFrame> {
     // SELECT SUM(scores) FROM table WHERE scores >= 3000 AND scores <= 4000
     df.filter(col("scores").gt_eq(lit(3_000)))?
         .filter(col("scores").lt_eq(lit(4_000)))?
-        .aggregate(vec![], vec![sum(col("scores"))])
+        .aggregate(vec![], vec![count_distinct(col("names"))])
 }
 
 fn measure_provider<M: Measurement>(
diff --git a/vortex-array/src/array/bool/accessors.rs b/vortex-array/src/array/bool/accessors.rs
index e35b25f8bf..6c464f1cff 100644
--- a/vortex-array/src/array/bool/accessors.rs
+++ b/vortex-array/src/array/bool/accessors.rs
@@ -1,4 +1,3 @@
-use itertools::Itertools;
 use vortex_error::VortexResult;
 
 use crate::accessor::ArrayAccessor;
@@ -22,7 +21,6 @@ impl ArrayAccessor<bool> for BoolArray {
             Validity::AllInvalid => Ok(f(&mut (0..self.len()).map(|_| None))),
             Validity::Array(valid) => {
                 let valids = valid.into_bool()?.boolean_buffer();
-                println!("nulls: {:?}", valids.iter().collect_vec());
                 let mut iter = valids.iter().zip(bools.iter()).map(|(is_valid, value)| {
                     if is_valid {
                         Some(if value { &TRUE } else { &FALSE })
diff --git a/vortex-array/src/array/varbin/compute/take.rs b/vortex-array/src/array/varbin/compute/take.rs
index 16bdf8fb21..2ce2b576f1 100644
--- a/vortex-array/src/array/varbin/compute/take.rs
+++ b/vortex-array/src/array/varbin/compute/take.rs
@@ -49,7 +49,7 @@ fn take<I: NativePType, O: NativePType>(
         return Ok(take_nullable(dtype, offsets, data, indices, v));
     }
 
-    let mut builder = VarBinBuilder::<I>::with_capacity(indices.len());
+    let mut builder = VarBinBuilder::<O>::with_capacity(indices.len());
     for &idx in indices {
         let idx = idx.to_usize().unwrap();
         let start = offsets[idx].to_usize().unwrap();
diff --git a/vortex-array/src/canonical.rs b/vortex-array/src/canonical.rs
index 6fbe21b251..2d737243fb 100644
--- a/vortex-array/src/canonical.rs
+++ b/vortex-array/src/canonical.rs
@@ -209,8 +209,7 @@ fn struct_to_arrow(struct_array: StructArray) -> ArrayRef {
 fn varbin_to_arrow(varbin_array: VarBinArray) -> ArrayRef {
     let offsets = varbin_array
         .offsets()
-        .into_canonical()
-        .and_then(Canonical::into_primitive)
+        .into_primitive()
         .expect("flatten_primitive");
     let offsets = match offsets.ptype() {
         PType::I32 | PType::I64 => offsets,
diff --git a/vortex-array/src/stats/statsset.rs b/vortex-array/src/stats/statsset.rs
index a2f9e85748..cc5dec36d5 100644
--- a/vortex-array/src/stats/statsset.rs
+++ b/vortex-array/src/stats/statsset.rs
@@ -27,36 +27,6 @@ impl StatsSet {
         }
     }
 
-    // pub fn constant(len: usize, scalar: &Scalar) -> Self {
-    //     let mut stats = HashMap::from([
-    //         (Stat::Max, scalar.clone()),
-    //         (Stat::Min, scalar.clone()),
-    //         (Stat::IsConstant, true.into()),
-    //         (Stat::IsSorted, true.into()),
-    //         (Stat::RunCount, 1.into()),
-    //     ]);
-    //
-    //     match scalar.dtype() {
-    //         DType::Bool(_) => {
-    //             stats.insert(Stat::TrueCount, 0.into());
-    //         }
-    //         DType::Primitive(ptype, _) => {
-    //             ptype.byte_width();
-    //             stats.insert(
-    //                 Stat::BitWidthFreq,
-    //                 vec![0; ptype.byte_width() * 8 + 1].into(),
-    //             );
-    //             stats.insert(
-    //                 Stat::TrailingZeroFreq,
-    //                 vec![ptype.byte_width() * 8; ptype.byte_width() * 8 + 1].into(),
-    //             );
-    //         }
-    //         _ => {}
-    //     }
-    //
-    //     Self::from(stats)
-    // }
-
     /// Specialized constructor for the case where the StatsSet represents
     /// an array consisting entirely of [null](vortex_dtype::DType::Null) values.
     pub fn nulls(len: usize, dtype: &DType) -> Self {