This is an automated email from the ASF dual-hosted git repository. avantgardner pushed a commit to branch bg_aggregate_pushdown in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
commit f50e7a9d5abcd90e4408323a5079f4876bce90e7 Author: Brent Gardner <[email protected]> AuthorDate: Tue Aug 1 11:03:14 2023 -0600 Pretty print physical plan --- datafusion/core/tests/sql/select.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/datafusion/core/tests/sql/select.rs b/datafusion/core/tests/sql/select.rs index 72cd10f195..a7366595c6 100644 --- a/datafusion/core/tests/sql/select.rs +++ b/datafusion/core/tests/sql/select.rs @@ -540,7 +540,13 @@ async fn parallel_query_with_filter() -> Result<()> { let dataframe = ctx .sql("SELECT c1, c2 FROM test WHERE c1 > 0 AND c1 < 3") .await?; - let results = dataframe.collect().await.unwrap(); + + let plan = dataframe.create_physical_plan().await?; + + let formatted = displayable(plan.as_ref()).indent(true).to_string(); + assert_eq!("", formatted); + + let results = collect(plan, ctx.task_ctx()).await?; let expected = vec