external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Normalize tests: s/assigned task [0-9]+ to node/assigned task to node/

pull/3336/head
Jelte Fennema 2020-01-03 11:45:22 +01:00
parent 7b833466ba
commit 96434e898f
4 changed files with 83 additions and 83 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/test/regress/bin/normalize.sed
View File

@ -11,7 +11,7 @@ s/localhost:[0-9]+/localhost:xxxxx/g
s/ port=[0-9]+ / port=xxxxx /g s/ port=[0-9]+ / port=xxxxx /g
s/placement [0-9]+/placement xxxxx/g s/placement [0-9]+/placement xxxxx/g
s/shard [0-9]+/shard xxxxx/g s/shard [0-9]+/shard xxxxx/g
#s/assigned task [0-9]+ to node/assigned task to node/ s/assigned task [0-9]+ to node/assigned task to node/
#s/node group [12] (but|does)/node group \1/ #s/node group [12] (but|does)/node group \1/
# #
## Differing names can have differing table column widths ## Differing names can have differing table column widths

102
src/test/regress/expected/multi_repartition_join_planning.out
View File

@ -71,8 +71,8 @@ DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT lineitem.l_partkey, orders.o_orderkey, lineitem.l_quantity, lineitem.l_extendedprice, orders.o_custkey FROM (lineitem_290000 lineitem JOIN orders_290002 orders ON ((lineitem.l_orderkey OPERATOR(pg_catalog.=) orders.o_orderkey))) WHERE ((lineitem.l_partkey OPERATOR(pg_catalog.<) 1000) AND (orders.o_totalprice OPERATOR(pg_catalog.>) 10.0))" DETAIL: query string: "SELECT lineitem.l_partkey, orders.o_orderkey, lineitem.l_quantity, lineitem.l_extendedprice, orders.o_custkey FROM (lineitem_290000 lineitem JOIN orders_290002 orders ON ((lineitem.l_orderkey OPERATOR(pg_catalog.=) orders.o_orderkey))) WHERE ((lineitem.l_partkey OPERATOR(pg_catalog.<) 1000) AND (orders.o_totalprice OPERATOR(pg_catalog.>) 10.0))"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT lineitem.l_partkey, orders.o_orderkey, lineitem.l_quantity, lineitem.l_extendedprice, orders.o_custkey FROM (lineitem_290001 lineitem JOIN orders_290003 orders ON ((lineitem.l_orderkey OPERATOR(pg_catalog.=) orders.o_orderkey))) WHERE ((lineitem.l_partkey OPERATOR(pg_catalog.<) 1000) AND (orders.o_totalprice OPERATOR(pg_catalog.>) 10.0))" DETAIL: query string: "SELECT lineitem.l_partkey, orders.o_orderkey, lineitem.l_quantity, lineitem.l_extendedprice, orders.o_custkey FROM (lineitem_290001 lineitem JOIN orders_290003 orders ON ((lineitem.l_orderkey OPERATOR(pg_catalog.=) orders.o_orderkey))) WHERE ((lineitem.l_partkey OPERATOR(pg_catalog.<) 1000) AND (orders.o_totalprice OPERATOR(pg_catalog.>) 10.0))"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for intervals [1,1000] and [6001,7000] DEBUG: join prunable for intervals [1,1000] and [6001,7000]
DEBUG: join prunable for intervals [6001,7000] and [1,1000] DEBUG: join prunable for intervals [6001,7000] and [1,1000]
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
@ -83,8 +83,8 @@ DEBUG: pruning merge fetch taskId 1
DETAIL: Creating dependency on merge taskId 3 DETAIL: Creating dependency on merge taskId 3
DEBUG: pruning merge fetch taskId 3 DEBUG: pruning merge fetch taskId 3
DETAIL: Creating dependency on merge taskId 6 DETAIL: Creating dependency on merge taskId 6
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for intervals [1,1000] and [1001,2000] DEBUG: join prunable for intervals [1,1000] and [1001,2000]
DEBUG: join prunable for intervals [1,1000] and [6001,7000] DEBUG: join prunable for intervals [1,1000] and [6001,7000]
DEBUG: join prunable for intervals [1001,2000] and [1,1000] DEBUG: join prunable for intervals [1001,2000] and [1,1000]
@ -103,9 +103,9 @@ DEBUG: pruning merge fetch taskId 3
DETAIL: Creating dependency on merge taskId 8 DETAIL: Creating dependency on merge taskId 8
DEBUG: pruning merge fetch taskId 5 DEBUG: pruning merge fetch taskId 5
DETAIL: Creating dependency on merge taskId 11 DETAIL: Creating dependency on merge taskId 11
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 3 DEBUG: completed cleanup query for job 3
DEBUG: completed cleanup query for job 3 DEBUG: completed cleanup query for job 3
DEBUG: completed cleanup query for job 2 DEBUG: completed cleanup query for job 2
@ -161,14 +161,14 @@ DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT l_partkey, l_suppkey FROM lineitem_290000 lineitem WHERE (l_quantity OPERATOR(pg_catalog.<) 5.0)" DETAIL: query string: "SELECT l_partkey, l_suppkey FROM lineitem_290000 lineitem WHERE (l_quantity OPERATOR(pg_catalog.<) 5.0)"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT l_partkey, l_suppkey FROM lineitem_290001 lineitem WHERE (l_quantity OPERATOR(pg_catalog.<) 5.0)" DETAIL: query string: "SELECT l_partkey, l_suppkey FROM lineitem_290001 lineitem WHERE (l_quantity OPERATOR(pg_catalog.<) 5.0)"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: generated sql query for task 1 DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE (o_totalprice OPERATOR(pg_catalog.<>) 4.0)" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE (o_totalprice OPERATOR(pg_catalog.<>) 4.0)"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE (o_totalprice OPERATOR(pg_catalog.<>) 4.0)" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE (o_totalprice OPERATOR(pg_catalog.<>) 4.0)"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -205,10 +205,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 6 DEBUG: completed cleanup query for job 6
DEBUG: completed cleanup query for job 6 DEBUG: completed cleanup query for job 6
DEBUG: completed cleanup query for job 4 DEBUG: completed cleanup query for job 4
@ -235,14 +235,14 @@ DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: generated sql query for task 1 DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -279,10 +279,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 9 DEBUG: completed cleanup query for job 9
DEBUG: completed cleanup query for job 9 DEBUG: completed cleanup query for job 9
DEBUG: completed cleanup query for job 7 DEBUG: completed cleanup query for job 7
@ -311,14 +311,14 @@ DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: generated sql query for task 1 DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -355,10 +355,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 12 DEBUG: completed cleanup query for job 12
DEBUG: completed cleanup query for job 12 DEBUG: completed cleanup query for job 12
DEBUG: completed cleanup query for job 10 DEBUG: completed cleanup query for job 10
@ -385,14 +385,14 @@ DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290000 lineitem WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true" DETAIL: query string: "SELECT l_suppkey FROM lineitem_290001 lineitem WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: generated sql query for task 1 DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290002 orders WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true" DETAIL: query string: "SELECT o_orderkey, o_shippriority FROM orders_290003 orders WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -429,10 +429,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 15 DEBUG: completed cleanup query for job 15
DEBUG: completed cleanup query for job 15 DEBUG: completed cleanup query for job 15
DEBUG: completed cleanup query for job 13 DEBUG: completed cleanup query for job 13
@ -461,10 +461,10 @@ DEBUG: generated sql query for task 3
DETAIL: query string: "SELECT s_i_id, s_w_id, s_quantity FROM stock_690006 stock WHERE true" DETAIL: query string: "SELECT s_i_id, s_w_id, s_quantity FROM stock_690006 stock WHERE true"
DEBUG: generated sql query for task 4 DEBUG: generated sql query for task 4
DETAIL: query string: "SELECT s_i_id, s_w_id, s_quantity FROM stock_690007 stock WHERE true" DETAIL: query string: "SELECT s_i_id, s_w_id, s_quantity FROM stock_690007 stock WHERE true"
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: generated sql query for task 1 DEBUG: generated sql query for task 1
DETAIL: query string: "SELECT ol_i_id FROM order_line_690000 order_line WHERE true" DETAIL: query string: "SELECT ol_i_id FROM order_line_690000 order_line WHERE true"
DEBUG: generated sql query for task 2 DEBUG: generated sql query for task 2
@ -473,10 +473,10 @@ DEBUG: generated sql query for task 3
DETAIL: query string: "SELECT ol_i_id FROM order_line_690002 order_line WHERE true" DETAIL: query string: "SELECT ol_i_id FROM order_line_690002 order_line WHERE true"
DEBUG: generated sql query for task 4 DEBUG: generated sql query for task 4
DETAIL: query string: "SELECT ol_i_id FROM order_line_690003 order_line WHERE true" DETAIL: query string: "SELECT ol_i_id FROM order_line_690003 order_line WHERE true"
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -513,10 +513,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 20 DETAIL: Creating dependency on merge taskId 20
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 20 DETAIL: Creating dependency on merge taskId 20
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: completed cleanup query for job 18 DEBUG: completed cleanup query for job 18
DEBUG: completed cleanup query for job 18 DEBUG: completed cleanup query for job 18
DEBUG: completed cleanup query for job 16 DEBUG: completed cleanup query for job 16

38
src/test/regress/expected/multi_repartition_join_task_assignment.out
View File

@ -18,8 +18,8 @@ FROM
WHERE WHERE
o_custkey = c_custkey; o_custkey = c_custkey;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for intervals [1,1000] and [1001,2000] DEBUG: join prunable for intervals [1,1000] and [1001,2000]
DEBUG: join prunable for intervals [1,1000] and [6001,7000] DEBUG: join prunable for intervals [1,1000] and [6001,7000]
DEBUG: join prunable for intervals [1001,2000] and [1,1000] DEBUG: join prunable for intervals [1001,2000] and [1,1000]
@ -32,9 +32,9 @@ DEBUG: pruning merge fetch taskId 3
DETAIL: Creating dependency on merge taskId 6 DETAIL: Creating dependency on merge taskId 6
DEBUG: pruning merge fetch taskId 5 DEBUG: pruning merge fetch taskId 5
DETAIL: Creating dependency on merge taskId 9 DETAIL: Creating dependency on merge taskId 9
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
count count
------- -------
2985 2985
@ -52,17 +52,17 @@ WHERE
o_custkey = c_custkey AND o_custkey = c_custkey AND
o_orderkey = l_orderkey; o_orderkey = l_orderkey;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for intervals [1,5986] and [8997,14947] DEBUG: join prunable for intervals [1,5986] and [8997,14947]
DEBUG: join prunable for intervals [8997,14947] and [1,5986] DEBUG: join prunable for intervals [8997,14947] and [1,5986]
DEBUG: pruning merge fetch taskId 1 DEBUG: pruning merge fetch taskId 1
DETAIL: Creating dependency on merge taskId 4 DETAIL: Creating dependency on merge taskId 4
DEBUG: pruning merge fetch taskId 3 DEBUG: pruning merge fetch taskId 3
DETAIL: Creating dependency on merge taskId 8 DETAIL: Creating dependency on merge taskId 8
DEBUG: assigned task 4 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
count count
------- -------
12000 12000
@ -77,11 +77,11 @@ FROM
WHERE WHERE
l_partkey = c_nationkey; l_partkey = c_nationkey;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: join prunable for task partitionId 0 and 1 DEBUG: join prunable for task partitionId 0 and 1
DEBUG: join prunable for task partitionId 0 and 2 DEBUG: join prunable for task partitionId 0 and 2
DEBUG: join prunable for task partitionId 0 and 3 DEBUG: join prunable for task partitionId 0 and 3
@ -110,10 +110,10 @@ DEBUG: pruning merge fetch taskId 10
DETAIL: Creating dependency on merge taskId 12 DETAIL: Creating dependency on merge taskId 12
DEBUG: pruning merge fetch taskId 11 DEBUG: pruning merge fetch taskId 11
DETAIL: Creating dependency on merge taskId 16 DETAIL: Creating dependency on merge taskId 16
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 6 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 9 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 12 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
count count
------- -------
125 125

24
src/test/regress/expected/multi_task_assignment_policy.out
View File

@ -70,9 +70,9 @@ SET client_min_messages TO DEBUG3;
SET citus.task_assignment_policy TO 'greedy'; SET citus.task_assignment_policy TO 'greedy';
EXPLAIN SELECT count(*) FROM task_assignment_test_table; EXPLAIN SELECT count(*) FROM task_assignment_test_table;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
QUERY PLAN QUERY PLAN
---------------------------------------------------------------------- ----------------------------------------------------------------------
Aggregate (cost=0.00..0.00 rows=0 width=0) Aggregate (cost=0.00..0.00 rows=0 width=0)
@ -82,9 +82,9 @@ DEBUG: assigned task 2 to node localhost:xxxxx
EXPLAIN SELECT count(*) FROM task_assignment_test_table; EXPLAIN SELECT count(*) FROM task_assignment_test_table;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
QUERY PLAN QUERY PLAN
---------------------------------------------------------------------- ----------------------------------------------------------------------
Aggregate (cost=0.00..0.00 rows=0 width=0) Aggregate (cost=0.00..0.00 rows=0 width=0)
@ -96,9 +96,9 @@ DEBUG: assigned task 2 to node localhost:xxxxx
SET citus.task_assignment_policy TO 'first-replica'; SET citus.task_assignment_policy TO 'first-replica';
EXPLAIN SELECT count(*) FROM task_assignment_test_table; EXPLAIN SELECT count(*) FROM task_assignment_test_table;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
QUERY PLAN QUERY PLAN
---------------------------------------------------------------------- ----------------------------------------------------------------------
Aggregate (cost=0.00..0.00 rows=0 width=0) Aggregate (cost=0.00..0.00 rows=0 width=0)
@ -108,9 +108,9 @@ DEBUG: assigned task 3 to node localhost:xxxxx
EXPLAIN SELECT count(*) FROM task_assignment_test_table; EXPLAIN SELECT count(*) FROM task_assignment_test_table;
DEBUG: Router planner does not support append-partitioned tables. DEBUG: Router planner does not support append-partitioned tables.
DEBUG: assigned task 1 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 2 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
DEBUG: assigned task 3 to node localhost:xxxxx DEBUG: assigned task to node localhost:xxxxx
QUERY PLAN QUERY PLAN
---------------------------------------------------------------------- ----------------------------------------------------------------------
Aggregate (cost=0.00..0.00 rows=0 width=0) Aggregate (cost=0.00..0.00 rows=0 width=0)