This is an automated email from the ASF dual-hosted git repository.

agrove pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git


The following commit(s) were added to refs/heads/master by this push:
     new bb365905 Enable more benchmark serde tests (#331)
bb365905 is described below

commit bb3659052990137b808d94a099b8b796cb20d345
Author: Andy Grove <[email protected]>
AuthorDate: Mon Oct 10 12:57:50 2022 -0600

    Enable more benchmark serde tests (#331)
---
 benchmarks/src/bin/tpch.rs | 27 ++++++++++++---------------
 1 file changed, 12 insertions(+), 15 deletions(-)

diff --git a/benchmarks/src/bin/tpch.rs b/benchmarks/src/bin/tpch.rs
index 00da201c..e70c7076 100644
--- a/benchmarks/src/bin/tpch.rs
+++ b/benchmarks/src/bin/tpch.rs
@@ -1500,21 +1500,6 @@ mod tests {
             // test logical plan round trip
             let plans = create_logical_plans(&ctx, n)?;
             for plan in plans {
-                let proto: datafusion_proto::protobuf::LogicalPlanNode =
-                    
datafusion_proto::protobuf::LogicalPlanNode::try_from_logical_plan(
-                        &plan,
-                        codec.logical_extension_codec(),
-                    )
-                    .unwrap();
-                let round_trip: LogicalPlan = proto
-                    .try_into_logical_plan(&ctx, 
codec.logical_extension_codec())
-                    .unwrap();
-                assert_eq!(
-                    format!("{:?}", plan),
-                    format!("{:?}", round_trip),
-                    "logical plan round trip failed"
-                );
-
                 // test optimized logical plan round trip
                 let plan = ctx.optimize(&plan)?;
                 let proto: datafusion_proto::protobuf::LogicalPlanNode =
@@ -1570,14 +1555,26 @@ mod tests {
         }
 
         test_round_trip!(q1, 1);
+        test_round_trip!(q2, 2);
         test_round_trip!(q3, 3);
+        test_round_trip!(q4, 4);
         test_round_trip!(q5, 5);
         test_round_trip!(q6, 6);
         test_round_trip!(q7, 7);
         test_round_trip!(q8, 8);
         test_round_trip!(q9, 9);
         test_round_trip!(q10, 10);
+        test_round_trip!(q11, 11);
         test_round_trip!(q12, 12);
         test_round_trip!(q13, 13);
+        test_round_trip!(q14, 14);
+        // test_round_trip!(q15, 15); 
https://github.com/apache/arrow-ballista/issues/330
+        // test_round_trip!(q16, 16); 
https://github.com/apache/arrow-ballista/issues/330
+        test_round_trip!(q17, 17);
+        test_round_trip!(q18, 18);
+        test_round_trip!(q19, 19);
+        test_round_trip!(q20, 20);
+        test_round_trip!(q21, 21);
+        // test_round_trip!(q22, 22); 
https://github.com/apache/arrow-ballista/issues/330
     }
 }

Reply via email to