From bc541dd5ab36c0636cf29fef9bc6ed77dbf4900f Mon Sep 17 00:00:00 2001 From: leiysky Date: Thu, 25 Aug 2022 13:09:35 +0800 Subject: [PATCH] fix tests --- .../suites/mode/cluster/exchange.test | 69 +++++++++---------- 1 file changed, 33 insertions(+), 36 deletions(-) diff --git a/tests/logictest/suites/mode/cluster/exchange.test b/tests/logictest/suites/mode/cluster/exchange.test index 05ea0a96998f0..a884a06c6207e 100644 --- a/tests/logictest/suites/mode/cluster/exchange.test +++ b/tests/logictest/suites/mode/cluster/exchange.test @@ -3,58 +3,55 @@ explain select * from numbers(1) t, numbers(2) t1 where t.number = t1.number; ---- Exchange(Merge) - HashJoin: INNER, build keys: [t1.number (#1)], probe keys: [t.number (#0)], join filters: [] - Exchange(Hash): keys: [t.number (#0)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t1.number (#1)] - Scan: default.system.numbers, filters: [] - +└── HashJoin: INNER, build keys: [t1.number (#1)], probe keys: [t.number (#0)], join filters: [] + ├── Exchange(Hash): keys: [t.number (#0)] + │ └── Scan: default.system.numbers, filters: [] + └── Exchange(Hash): keys: [t1.number (#1)] + └── Scan: default.system.numbers, filters: [] statement query T explain select * from numbers(1) t, numbers(2) t1, numbers(3) t2 where t.number = t1.number and t.number = t2.number; ---- Exchange(Merge) - HashJoin: INNER, build keys: [t2.number (#2)], probe keys: [t.number (#0)], join filters: [] - HashJoin: INNER, build keys: [t1.number (#1)], probe keys: [t.number (#0)], join filters: [] - Exchange(Hash): keys: [t.number (#0)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t1.number (#1)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t2.number (#2)] - Scan: default.system.numbers, filters: [] - +└── HashJoin: INNER, build keys: [t2.number (#2)], probe keys: [t.number (#0)], join filters: [] + ├── HashJoin: INNER, build keys: [t1.number (#1)], probe keys: [t.number (#0)], join filters: [] + │ ├── Exchange(Hash): keys: [t.number (#0)] + │ │ └── Scan: default.system.numbers, filters: [] + │ └── Exchange(Hash): keys: [t1.number (#1)] + │ └── Scan: default.system.numbers, filters: [] + └── Exchange(Hash): keys: [t2.number (#2)] + └── Scan: default.system.numbers, filters: [] statement query T explain select * from (select number as a, number+1 as b from numbers(1)) t, numbers(2) t1, numbers(3) t2 where a = t1.number and b = t2.number; ---- Exchange(Merge) - HashJoin: INNER, build keys: [t2.number (#4)], probe keys: [t.b (#1)], join filters: [] - Exchange(Hash): keys: [t.b (#1)] - HashJoin: INNER, build keys: [t1.number (#3)], probe keys: [t.a (#0)], join filters: [] - Exchange(Hash): keys: [t.a (#0)] - EvalScalar: [+(numbers.number (#0), 1)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t1.number (#3)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t2.number (#4)] - Scan: default.system.numbers, filters: [] - +└── HashJoin: INNER, build keys: [t2.number (#4)], probe keys: [t.b (#1)], join filters: [] + ├── Exchange(Hash): keys: [t.b (#1)] + │ └── HashJoin: INNER, build keys: [t1.number (#3)], probe keys: [t.a (#0)], join filters: [] + │ ├── Exchange(Hash): keys: [t.a (#0)] + │ │ └── EvalScalar: [+(numbers.number (#0), 1)] + │ │ └── Scan: default.system.numbers, filters: [] + │ └── Exchange(Hash): keys: [t1.number (#3)] + │ └── Scan: default.system.numbers, filters: [] + └── Exchange(Hash): keys: [t2.number (#4)] + └── Scan: default.system.numbers, filters: [] statement query T explain select * from (select sum(number) as number from numbers(1) group by number) t, numbers(2) t1 where t.number = t1.number; ---- Exchange(Merge) - HashJoin: INNER, build keys: [t1.number (#4)], probe keys: [t.number (#1)], join filters: [] - Exchange(Hash): keys: [t.number (#1)] - Project: [number (#1)] - EvalScalar: [sum(number) (#3)] - Aggregate(Final): group items: [numbers.number (#0)], aggregate functions: [sum(number)] - Aggregate(Partial): group items: [numbers.number (#0)], aggregate functions: [sum(number)] - Exchange(Hash): keys: [numbers.number (#0)] - Scan: default.system.numbers, filters: [] - Exchange(Hash): keys: [t1.number (#4)] - Scan: default.system.numbers, filters: [] +└── HashJoin: INNER, build keys: [t1.number (#4)], probe keys: [t.number (#1)], join filters: [] + ├── Exchange(Hash): keys: [t.number (#1)] + │ └── Project: [number (#1)] + │ └── EvalScalar: [sum(number) (#3)] + │ └── Aggregate(Final): group items: [numbers.number (#0)], aggregate functions: [sum(number)] + │ └── Aggregate(Partial): group items: [numbers.number (#0)], aggregate functions: [sum(number)] + │ └── Exchange(Hash): keys: [numbers.number (#0)] + │ └── Scan: default.system.numbers, filters: [] + └── Exchange(Hash): keys: [t1.number (#4)] + └── Scan: default.system.numbers, filters: []