From d0c10613d79dad0aed952c4e0a43845d8b6fb99a Mon Sep 17 00:00:00 2001 From: Liang-Chi Hsieh Date: Wed, 9 Oct 2024 15:31:24 -0600 Subject: [PATCH] try to output error --- native/core/src/execution/datafusion/shuffle_writer.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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]