diff --git a/native/core/src/execution/datafusion/shuffle_writer.rs b/native/core/src/execution/datafusion/shuffle_writer.rs index f0078e883a..4894c94ed1 100644 --- a/native/core/src/execution/datafusion/shuffle_writer.rs +++ b/native/core/src/execution/datafusion/shuffle_writer.rs @@ -1646,7 +1646,8 @@ mod test { let task_ctx = ctx.task_ctx(); let stream = exec.execute(0, task_ctx).unwrap(); let rt = Runtime::new().unwrap(); - rt.block_on(collect(stream)).unwrap(); + let ret = rt.block_on(collect(stream)); + println!("ret: {:?}", ret); } #[test]