Skip to content

Commit

Permalink
fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
@winoros
winoros committed May 24, 2023
1 parent 51a1178 commit 34864c8
Showing 1 changed file with 87 additions and 87 deletions.
174 changes: 87 additions & 87 deletions planner/core/casetest/testdata/enforce_mpp_suite_out.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1598,33 +1598,33 @@
{
"SQL": "explain format = 'brief' with c1 as (select * from t) select * from c1, c1 c2 where c1.a=c2.b ",
"Plan": [
"TableReader 8000.00 root MppVersion: 1, data:ExchangeSender",
"└─ExchangeSender 8000.00 mpp[tiflash] ExchangeType: PassThrough",
" └─Sequence 8000.00 mpp[tiflash] Sequence Node",
" ├─CTE_0 8000.00 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 8000.00 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
" └─HashJoin 8000.00 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 6400.00 mpp[tiflash] ",
" │ └─ExchangeSender 6400.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 6400.00 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 6400.00 mpp[tiflash] not(isnull(test.t.b))",
" └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
"TableReader 9999.99 root MppVersion: 1, data:ExchangeSender",
"└─ExchangeSender 9999.99 mpp[tiflash] ExchangeType: PassThrough",
" └─Sequence 9999.99 mpp[tiflash] Sequence Node",
" ├─CTE_0 9999.99 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 9999.99 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
" └─HashJoin 9999.99 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 7999.99 mpp[tiflash] ",
" │ └─ExchangeSender 7999.99 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 7999.99 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 7999.99 mpp[tiflash] not(isnull(test.t.b))",
" └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
],
"Warn": null
},
{
"SQL": "explain format = 'brief' with c1 as (select /*+ read_from_storage(tikv[t]) */ * from t) select * from c1, c1 c2 where c1.a=c2.b ",
"Plan": [
"HashJoin 8000.00 root inner join, equal:[eq(test.t.a, test.t.b)]",
"├─Selection(Build) 6400.00 root not(isnull(test.t.b))",
"│ └─CTEFullScan 8000.00 root CTE:c1 AS c2 data:CTE_0",
"└─Selection(Probe) 6400.00 root not(isnull(test.t.a))",
" └─CTEFullScan 8000.00 root CTE:c1 data:CTE_0",
"CTE_0 8000.00 root Non-Recursive CTE",
"└─Selection(Seed Part) 8000.00 root or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" └─TableReader 10000.00 root data:TableFullScan",
"HashJoin 9999.99 root inner join, equal:[eq(test.t.a, test.t.b)]",
"├─Selection(Build) 7999.99 root not(isnull(test.t.b))",
"│ └─CTEFullScan 9999.99 root CTE:c1 AS c2 data:CTE_0",
"└─Selection(Probe) 7999.99 root not(isnull(test.t.a))",
" └─CTEFullScan 9999.99 root CTE:c1 data:CTE_0",
"CTE_0 9999.99 root Non-Recursive CTE",
"└─TableReader(Seed Part) 9999.99 root data:Selection",
" └─Selection 9999.99 cop[tikv] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" └─TableFullScan 10000.00 cop[tikv] table:t keep order:false, stats:pseudo"
],
"Warn": [
Expand All @@ -1634,20 +1634,20 @@
{
"SQL": "explain format = 'brief' with c1 as (select * from t) select c1.* from c1, c1 c2 where c1.b=c2.c",
"Plan": [
"TableReader 8000.00 root MppVersion: 1, data:ExchangeSender",
"└─ExchangeSender 8000.00 mpp[tiflash] ExchangeType: PassThrough",
" └─Projection 8000.00 mpp[tiflash] test.t.a, test.t.b, test.t.c",
" └─Sequence 8000.00 mpp[tiflash] Sequence Node",
" ├─CTE_0 8000.00 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 8000.00 mpp[tiflash] or(not(isnull(test.t.b)), not(isnull(test.t.c)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
" └─HashJoin 8000.00 mpp[tiflash] inner join, equal:[eq(test.t.b, test.t.c)]",
" ├─ExchangeReceiver(Build) 6400.00 mpp[tiflash] ",
" │ └─ExchangeSender 6400.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 6400.00 mpp[tiflash] not(isnull(test.t.b))",
" │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 6400.00 mpp[tiflash] not(isnull(test.t.c))",
" └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
"TableReader 9999.99 root MppVersion: 1, data:ExchangeSender",
"└─ExchangeSender 9999.99 mpp[tiflash] ExchangeType: PassThrough",
" └─Projection 9999.99 mpp[tiflash] test.t.a, test.t.b, test.t.c",
" └─Sequence 9999.99 mpp[tiflash] Sequence Node",
" ├─CTE_0 9999.99 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 9999.99 mpp[tiflash] or(not(isnull(test.t.b)), not(isnull(test.t.c)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
" └─HashJoin 9999.99 mpp[tiflash] inner join, equal:[eq(test.t.b, test.t.c)]",
" ├─ExchangeReceiver(Build) 7999.99 mpp[tiflash] ",
" │ └─ExchangeSender 7999.99 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 7999.99 mpp[tiflash] not(isnull(test.t.b))",
" │ └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 7999.99 mpp[tiflash] not(isnull(test.t.c))",
" └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
],
"Warn": null
},
Expand All @@ -1658,17 +1658,17 @@
"└─TableReader 10.00 root MppVersion: 1, data:ExchangeSender",
" └─ExchangeSender 10.00 mpp[tiflash] ExchangeType: PassThrough",
" └─Limit 10.00 mpp[tiflash] offset:0, count:10",
" └─Sequence 8000.00 mpp[tiflash] Sequence Node",
" ├─CTE_0 8000.00 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 8000.00 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
" └─HashJoin 8000.00 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 6400.00 mpp[tiflash] ",
" │ └─ExchangeSender 6400.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 6400.00 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Sequence 9999.99 mpp[tiflash] Sequence Node",
" ├─CTE_0 9999.99 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 9999.99 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
" └─HashJoin 9999.99 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 7999.99 mpp[tiflash] ",
" │ └─ExchangeSender 7999.99 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 7999.99 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 8.00 mpp[tiflash] not(isnull(test.t.b))",
" └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
" └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
],
"Warn": null
},
Expand All @@ -1679,17 +1679,17 @@
"└─TableReader 10.00 root MppVersion: 1, data:ExchangeSender",
" └─ExchangeSender 10.00 mpp[tiflash] ExchangeType: PassThrough",
" └─TopN 10.00 mpp[tiflash] test.t.a, offset:0, count:10",
" └─Sequence 8000.00 mpp[tiflash] Sequence Node",
" ├─CTE_0 8000.00 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 8000.00 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
" └─HashJoin 8000.00 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 6400.00 mpp[tiflash] ",
" │ └─ExchangeSender 6400.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 6400.00 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 6400.00 mpp[tiflash] not(isnull(test.t.b))",
" └─CTEFullScan 8000.00 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
" └─Sequence 9999.99 mpp[tiflash] Sequence Node",
" ├─CTE_0 9999.99 mpp[tiflash] Non-Recursive CTE Storage",
" │ └─Selection 9999.99 mpp[tiflash] or(not(isnull(test.t.a)), not(isnull(test.t.b)))",
" │ └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
" └─HashJoin 9999.99 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 7999.99 mpp[tiflash] ",
" │ └─ExchangeSender 7999.99 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Selection 7999.99 mpp[tiflash] not(isnull(test.t.a))",
" │ └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 data:CTE_0",
" └─Selection(Probe) 7999.99 mpp[tiflash] not(isnull(test.t.b))",
" └─CTEFullScan 9999.99 mpp[tiflash] CTE:c1 AS c2 data:CTE_0"
],
"Warn": null
},
Expand Down Expand Up @@ -1761,19 +1761,19 @@
" │ └─Selection(Probe) 8000.00 mpp[tiflash] not(isnull(test.t.c))",
" │ └─CTEFullScan 10000.00 mpp[tiflash] CTE:c1 AS c2 data:CTE_0",
" └─HashJoin 19531.25 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.a)]",
" ├─ExchangeReceiver(Build) 8000.00 mpp[tiflash] ",
" │ └─ExchangeSender 8000.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Sequence 8000.00 mpp[tiflash] Sequence Node",
" │ ├─CTE_2 8000.00 mpp[tiflash] Non-Recursive CTE Storage",
" │ │ └─Selection 8000.00 mpp[tiflash] or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" │ │ └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
" │ └─HashJoin 8000.00 mpp[tiflash] inner join, equal:[eq(test.t.c, test.t.b)]",
" │ ├─ExchangeReceiver(Build) 6400.00 mpp[tiflash] ",
" │ │ └─ExchangeSender 6400.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ │ └─Selection 6400.00 mpp[tiflash] not(isnull(test.t.a)), not(isnull(test.t.c))",
" │ │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c3 data:CTE_2",
" │ └─Selection(Probe) 6400.00 mpp[tiflash] not(isnull(test.t.b))",
" │ └─CTEFullScan 8000.00 mpp[tiflash] CTE:c3 AS c4 data:CTE_2",
" ├─ExchangeReceiver(Build) 9999.98 mpp[tiflash] ",
" │ └─ExchangeSender 9999.98 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ └─Sequence 9999.98 mpp[tiflash] Sequence Node",
" │ ├─CTE_2 9999.98 mpp[tiflash] Non-Recursive CTE Storage",
" │ │ └─Selection 9999.98 mpp[tiflash] or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" │ │ └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
" │ └─HashJoin 9999.98 mpp[tiflash] inner join, equal:[eq(test.t.c, test.t.b)]",
" │ ├─ExchangeReceiver(Build) 7999.98 mpp[tiflash] ",
" │ │ └─ExchangeSender 7999.98 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
" │ │ └─Selection 7999.98 mpp[tiflash] not(isnull(test.t.a)), not(isnull(test.t.c))",
" │ │ └─CTEFullScan 9999.98 mpp[tiflash] CTE:c3 data:CTE_2",
" │ └─Selection(Probe) 7999.98 mpp[tiflash] not(isnull(test.t.b))",
" │ └─CTEFullScan 9999.98 mpp[tiflash] CTE:c3 AS c4 data:CTE_2",
" └─HashJoin(Probe) 12500.00 mpp[tiflash] inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─ExchangeReceiver(Build) 8000.00 mpp[tiflash] ",
" │ └─ExchangeSender 8000.00 mpp[tiflash] ExchangeType: Broadcast, Compression: FAST",
Expand All @@ -1788,21 +1788,21 @@
"SQL": "explain format = 'brief' with c1 as (select /*+ read_from_storage(tikv[t]) */ * from t), c2 as (select c1.* from c1, c1 c2 where c1.b=c2.c) select * from c2 c1, c2, (with c3 as (select * from t) select c3.* from c3, c3 c4 where c3.c=c4.b) c3 where c1.a=c2.b and c1.a=c3.a",
"Plan": [
"HashJoin 19531.25 root inner join, equal:[eq(test.t.a, test.t.a)]",
"├─HashJoin(Build) 8000.00 root inner join, equal:[eq(test.t.c, test.t.b)]",
"│ ├─Selection(Build) 6400.00 root not(isnull(test.t.b))",
"│ │ └─CTEFullScan 8000.00 root CTE:c3 AS c4 data:CTE_2",
"│ └─Selection(Probe) 6400.00 root not(isnull(test.t.a)), not(isnull(test.t.c))",
"│ └─CTEFullScan 8000.00 root CTE:c3 data:CTE_2",
"├─HashJoin(Build) 9999.98 root inner join, equal:[eq(test.t.c, test.t.b)]",
"│ ├─Selection(Build) 7999.98 root not(isnull(test.t.b))",
"│ │ └─CTEFullScan 9999.98 root CTE:c3 AS c4 data:CTE_2",
"│ └─Selection(Probe) 7999.98 root not(isnull(test.t.a)), not(isnull(test.t.c))",
"│ └─CTEFullScan 9999.98 root CTE:c3 data:CTE_2",
"└─HashJoin(Probe) 12500.00 root inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─Selection(Build) 8000.00 root not(isnull(test.t.b))",
" │ └─CTEFullScan 10000.00 root CTE:c2 data:CTE_1",
" └─Selection(Probe) 8000.00 root not(isnull(test.t.a))",
" └─CTEFullScan 10000.00 root CTE:c2 AS c1 data:CTE_1",
"CTE_2 8000.00 root Non-Recursive CTE",
"└─TableReader(Seed Part) 8000.00 root MppVersion: 1, data:ExchangeSender",
" └─ExchangeSender 8000.00 mpp[tiflash] ExchangeType: PassThrough",
" └─Selection 8000.00 mpp[tiflash] or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" └─TableFullScan 10000.00 mpp[tiflash] table:t keep order:false, stats:pseudo",
"CTE_2 9999.98 root Non-Recursive CTE",
"└─TableReader(Seed Part) 9999.98 root MppVersion: 1, data:ExchangeSender",
" └─ExchangeSender 9999.98 mpp[tiflash] ExchangeType: PassThrough",
" └─Selection 9999.98 mpp[tiflash] or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" └─TableFullScan 10000.00 mpp[tiflash] table:t pushed down filter:empty, keep order:false, stats:pseudo",
"CTE_1 10000.00 root Non-Recursive CTE",
"└─HashJoin(Seed Part) 10000.00 root inner join, equal:[eq(test.t.b, test.t.c)]",
" ├─Selection(Build) 8000.00 root not(isnull(test.t.c))",
Expand All @@ -1821,19 +1821,19 @@
"SQL": "explain format = 'brief' with c1 as (select * from t), c2 as (select c1.* from c1, c1 c2 where c1.b=c2.c) select * from c2 c1, c2, (with c3 as (select /*+ read_from_storage(tikv[t]) */ * from t) select c3.* from c3, c3 c4 where c3.c=c4.b) c3 where c1.a=c2.b and c1.a=c3.a",
"Plan": [
"HashJoin 19531.25 root inner join, equal:[eq(test.t.a, test.t.a)]",
"├─HashJoin(Build) 8000.00 root inner join, equal:[eq(test.t.c, test.t.b)]",
"│ ├─Selection(Build) 6400.00 root not(isnull(test.t.b))",
"│ │ └─CTEFullScan 8000.00 root CTE:c3 AS c4 data:CTE_2",
"│ └─Selection(Probe) 6400.00 root not(isnull(test.t.a)), not(isnull(test.t.c))",
"│ └─CTEFullScan 8000.00 root CTE:c3 data:CTE_2",
"├─HashJoin(Build) 9999.98 root inner join, equal:[eq(test.t.c, test.t.b)]",
"│ ├─Selection(Build) 7999.98 root not(isnull(test.t.b))",
"│ │ └─CTEFullScan 9999.98 root CTE:c3 AS c4 data:CTE_2",
"│ └─Selection(Probe) 7999.98 root not(isnull(test.t.a)), not(isnull(test.t.c))",
"│ └─CTEFullScan 9999.98 root CTE:c3 data:CTE_2",
"└─HashJoin(Probe) 12500.00 root inner join, equal:[eq(test.t.a, test.t.b)]",
" ├─Selection(Build) 8000.00 root not(isnull(test.t.b))",
" │ └─CTEFullScan 10000.00 root CTE:c2 data:CTE_1",
" └─Selection(Probe) 8000.00 root not(isnull(test.t.a))",
" └─CTEFullScan 10000.00 root CTE:c2 AS c1 data:CTE_1",
"CTE_2 8000.00 root Non-Recursive CTE",
"└─Selection(Seed Part) 8000.00 root or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" └─TableReader 10000.00 root data:TableFullScan",
"CTE_2 9999.98 root Non-Recursive CTE",
"└─TableReader(Seed Part) 9999.98 root data:Selection",
" └─Selection 9999.98 cop[tikv] or(and(not(isnull(test.t.c)), not(isnull(test.t.a))), not(isnull(test.t.b)))",
" └─TableFullScan 10000.00 cop[tikv] table:t keep order:false, stats:pseudo",
"CTE_1 10000.00 root Non-Recursive CTE",
"└─HashJoin(Seed Part) 10000.00 root inner join, equal:[eq(test.t.b, test.t.c)]",
Expand Down

0 comments on commit 34864c8

Please sign in to comment.