diff --git a/rust-toolchain.toml b/rust-toolchain.toml index 28130b1dc..cc6d07f37 100644 --- a/rust-toolchain.toml +++ b/rust-toolchain.toml @@ -1,3 +1,3 @@ [toolchain] -channel = "1.91" +channel = "1.94.0" profile = "default" diff --git a/src/execution_plans/sampler.rs b/src/execution_plans/sampler.rs index 8eb5c3642..5c8bb5a02 100644 --- a/src/execution_plans/sampler.rs +++ b/src/execution_plans/sampler.rs @@ -255,6 +255,7 @@ impl PartitionSampler { // The input produced nothing at all: the stream is exhausted, so this partition // reached EOS with zero rows. reporter.load_info.reached_eos = true; + reporter.report(&peek); return Ok(peek.chain(input_stream).boxed()); }; let _guard = elapsed_compute.timer();