fix: update sqlness result in distributed mode (GreptimeTeam#2381)

Signed-off-by: Ruihang Xia <[email protected]>
paomian · Oct 19, 2023 · f862355 · f862355
1 parent 9b9193f
commit f862355
Show file tree

Hide file tree

Showing 16 changed files with 111 additions and 101 deletions.
diff --git a/tests/cases/distributed/explain/join_10_tables.result b/tests/cases/distributed/explain/join_10_tables.result
@@ -42,7 +42,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain 
 select * 
 from 
@@ -122,45 +122,45 @@ limit 1;
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_FilterExec: vin@1 IS NOT NULL_|
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_FilterExec: vin@1 IS NOT NULL_|
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 

diff --git a/tests/cases/distributed/explain/join_10_tables.sql b/tests/cases/distributed/explain/join_10_tables.sql
@@ -13,7 +13,7 @@ create table t_10 (ts timestamp time index, vin string, val int);
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain 
 select * 
 from 

diff --git a/tests/cases/distributed/explain/multi_partitions.result b/tests/cases/distributed/explain/multi_partitions.result
@@ -19,7 +19,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain SELECT * FROM demo WHERE ts > cast(1000000000 as timestamp) ORDER BY host;
 
 +-+-+
@@ -28,7 +28,7 @@ explain SELECT * FROM demo WHERE ts > cast(1000000000 as timestamp) ORDER BY hos
 | logical_plan_| Sort: demo.host ASC NULLS LAST_|
 |_|_MergeScan [is_placeholder=false]_|
 | physical_plan | SortExec: expr=[host@0 ASC NULLS LAST]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 

diff --git a/tests/cases/distributed/explain/multi_partitions.sql b/tests/cases/distributed/explain/multi_partitions.sql
@@ -17,7 +17,7 @@ PARTITION BY RANGE COLUMNS (host) (
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain SELECT * FROM demo WHERE ts > cast(1000000000 as timestamp) ORDER BY host;
 
 drop table demo;
diff --git a/tests/cases/distributed/explain/order_by.result b/tests/cases/distributed/explain/order_by.result
@@ -6,7 +6,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT DISTINCT i%2 FROM integers ORDER BY 1;
 
 +-+-+
@@ -22,7 +22,7 @@ EXPLAIN SELECT DISTINCT i%2 FROM integers ORDER BY 1;
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_AggregateExec: mode=Partial, gby=[integers.i % Int64(2)@0 as integers.i % Int64(2)], aggr=[]_|
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
@@ -38,7 +38,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT a, b FROM test ORDER BY a, b;
 
 +-+-+
@@ -47,15 +47,15 @@ EXPLAIN SELECT a, b FROM test ORDER BY a, b;
 | logical_plan_| Sort: test.a ASC NULLS LAST, test.b ASC NULLS LAST_|
 |_|_MergeScan [is_placeholder=false]_|
 | physical_plan | SortExec: expr=[a@0 ASC NULLS LAST,b@1 ASC NULLS LAST] |
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT DISTINCT a, b FROM test ORDER BY a, b;
 
 +-+-+
@@ -71,7 +71,7 @@ EXPLAIN SELECT DISTINCT a, b FROM test ORDER BY a, b;
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_AggregateExec: mode=Partial, gby=[a@0 as a, b@1 as b], aggr=[]_|
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 

diff --git a/tests/cases/distributed/explain/order_by.sql b/tests/cases/distributed/explain/order_by.sql
@@ -4,7 +4,7 @@ CREATE TABLE integers(i BIGINT, ts TIMESTAMP TIME INDEX);
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT DISTINCT i%2 FROM integers ORDER BY 1;
 
 DROP TABLE integers;
@@ -16,14 +16,14 @@ CREATE TABLE test (a INTEGER, b INTEGER, t TIMESTAMP TIME INDEX);
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT a, b FROM test ORDER BY a, b;
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT DISTINCT a, b FROM test ORDER BY a, b;
 
 DROP TABLE test;
diff --git a/tests/cases/distributed/explain/single_partition.result b/tests/cases/distributed/explain/single_partition.result
@@ -6,7 +6,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT COUNT(*) FROM single_partition;
 
 +-+-+
@@ -20,15 +20,15 @@ EXPLAIN SELECT COUNT(*) FROM single_partition;
 |_|_AggregateExec: mode=Partial, gby=[], aggr=[COUNT(UInt8(1))]_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_ProjectionExec: expr=[]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT SUM(i) FROM single_partition;
 
 +-+-+
@@ -42,15 +42,15 @@ EXPLAIN SELECT SUM(i) FROM single_partition;
 |_|_AggregateExec: mode=Partial, gby=[], aggr=[SUM(single_partition.i)]_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_ProjectionExec: expr=[i@0 as i]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM single_partition ORDER BY i DESC;
 
 +-+-+
@@ -59,7 +59,7 @@ EXPLAIN SELECT * FROM single_partition ORDER BY i DESC;
 | logical_plan_| Sort: single_partition.i DESC NULLS FIRST_|
 |_|_MergeScan [is_placeholder=false]_|
 | physical_plan | SortExec: expr=[i@0 DESC]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 

diff --git a/tests/cases/distributed/explain/single_partition.sql b/tests/cases/distributed/explain/single_partition.sql
@@ -4,21 +4,21 @@ CREATE TABLE single_partition(i DOUBLE, j TIMESTAMP TIME INDEX, k STRING PRIMARY
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT COUNT(*) FROM single_partition;
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT SUM(i) FROM single_partition;
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM single_partition ORDER BY i DESC;
 
 drop table single_partition;
diff --git a/tests/cases/distributed/explain/subqueries.result b/tests/cases/distributed/explain/subqueries.result
@@ -6,7 +6,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM integers WHERE i IN ((SELECT i FROM integers)) ORDER BY i;
 
 +-+-+
@@ -24,19 +24,19 @@ EXPLAIN SELECT * FROM integers WHERE i IN ((SELECT i FROM integers)) ORDER BY i;
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM integers i1 WHERE EXISTS(SELECT i FROM integers WHERE i=i1.i) ORDER BY i1.i;
 
 +-+-+
@@ -56,12 +56,12 @@ EXPLAIN SELECT * FROM integers i1 WHERE EXISTS(SELECT i FROM integers WHERE i=i1
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_ProjectionExec: expr=[i@0 as i]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 
@@ -73,7 +73,7 @@ Affected Rows: 0
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain select t.i
 from (
     select * from integers join other on 1=1
@@ -95,13 +95,13 @@ order by t.i desc;
 | physical_plan | SortExec: expr=[i@0 DESC]_|
 |_|_NestedLoopJoinExec: join_type=Inner_|
 |_|_ProjectionExec: expr=[]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_CoalescePartitionsExec_|
 |_|_CoalesceBatchesExec: target_batch_size=8192_|
 |_|_FilterExec: i@0 IS NOT NULL_|
 |_|_RepartitionExec: partitioning=REDACTED
 |_|_ProjectionExec: expr=[i@0 as i]_|
-|_|_MergeScanExec: peers=[REDACTED
+|_|_MergeScanExec: REDACTED
 |_|_|
 +-+-+
 

diff --git a/tests/cases/distributed/explain/subqueries.sql b/tests/cases/distributed/explain/subqueries.sql
@@ -4,14 +4,14 @@ CREATE TABLE integers(i INTEGER, j TIMESTAMP TIME INDEX);
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM integers WHERE i IN ((SELECT i FROM integers)) ORDER BY i;
 
 -- SQLNESS REPLACE (-+) -
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 EXPLAIN SELECT * FROM integers i1 WHERE EXISTS(SELECT i FROM integers WHERE i=i1.i) ORDER BY i1.i;
 
 create table other (i INTEGER, j TIMESTAMP TIME INDEX);
@@ -20,7 +20,7 @@ create table other (i INTEGER, j TIMESTAMP TIME INDEX);
 -- SQLNESS REPLACE (\s\s+) _
 -- SQLNESS REPLACE (RoundRobinBatch.*) REDACTED
 -- SQLNESS REPLACE (Hash.*) REDACTED
--- SQLNESS REPLACE (peer-.*) REDACTED
+-- SQLNESS REPLACE (peers.*) REDACTED
 explain select t.i
 from (
     select * from integers join other on 1=1