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

update isolation tests for repartitioning

pull/3850/head
Sait Talha Nisanci 2020-05-19 14:19:35 +03:00
parent 1c2ee39f15
commit 52e6e82ad8
10 changed files with 155 additions and 102 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/test/regress/expected/isolation_append_copy_vs_all.out
View File

@ -60,8 +60,9 @@ step s1-initialize: COPY append_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-copy: COPY append_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV; step s1-copy: COPY append_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -399,8 +400,9 @@ create_distributed_table
step s1-initialize: COPY append_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY append_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data

42
src/test/regress/expected/isolation_hash_copy_vs_all.out
View File

@ -60,8 +60,9 @@ step s1-initialize: COPY hash_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 &&
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-copy: COPY hash_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV; step s1-copy: COPY hash_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -356,10 +357,10 @@ create_distributed_table
step s1-recreate-with-replication-2: step s1-recreate-with-replication-2:
DROP TABLE hash_copy; DROP TABLE hash_copy;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
CREATE TABLE hash_copy(id integer, data text, int_data int); CREATE TABLE hash_copy(id integer, data text, int_data int);
SELECT create_distributed_table('hash_copy', 'id'); SELECT create_distributed_table('hash_copy', 'id');
create_distributed_table create_distributed_table
@ -380,10 +381,10 @@ create_distributed_table
step s1-recreate-with-replication-2: step s1-recreate-with-replication-2:
DROP TABLE hash_copy; DROP TABLE hash_copy;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
CREATE TABLE hash_copy(id integer, data text, int_data int); CREATE TABLE hash_copy(id integer, data text, int_data int);
SELECT create_distributed_table('hash_copy', 'id'); SELECT create_distributed_table('hash_copy', 'id');
create_distributed_table create_distributed_table
@ -404,10 +405,10 @@ create_distributed_table
step s1-recreate-with-replication-2: step s1-recreate-with-replication-2:
DROP TABLE hash_copy; DROP TABLE hash_copy;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
CREATE TABLE hash_copy(id integer, data text, int_data int); CREATE TABLE hash_copy(id integer, data text, int_data int);
SELECT create_distributed_table('hash_copy', 'id'); SELECT create_distributed_table('hash_copy', 'id');
create_distributed_table create_distributed_table
@ -428,10 +429,10 @@ create_distributed_table
step s1-recreate-with-replication-2: step s1-recreate-with-replication-2:
DROP TABLE hash_copy; DROP TABLE hash_copy;
SET citus.shard_replication_factor TO 2; SET citus.shard_replication_factor TO 2;
CREATE TABLE hash_copy(id integer, data text, int_data int); CREATE TABLE hash_copy(id integer, data text, int_data int);
SELECT create_distributed_table('hash_copy', 'id'); SELECT create_distributed_table('hash_copy', 'id');
create_distributed_table create_distributed_table
@ -492,8 +493,9 @@ create_distributed_table
step s1-initialize: COPY hash_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY hash_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data

10
src/test/regress/expected/isolation_partitioned_copy_vs_all.out
View File

@ -60,8 +60,9 @@ step s1-initialize: COPY partitioned_copy FROM PROGRAM 'echo 0, a, 0 && echo 1,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-copy: COPY partitioned_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV; step s1-copy: COPY partitioned_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -335,8 +336,9 @@ create_distributed_table
step s1-initialize: COPY partitioned_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY partitioned_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data

10
src/test/regress/expected/isolation_range_copy_vs_all.out
View File

@ -60,8 +60,9 @@ step s1-initialize: COPY range_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 &
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-copy: COPY range_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV; step s1-copy: COPY range_copy FROM PROGRAM 'echo 5, f, 5 && echo 6, g, 6 && echo 7, h, 7 && echo 8, i, 8 && echo 9, j, 9' WITH CSV;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -413,8 +414,9 @@ create_distributed_table
step s1-initialize: COPY range_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY range_copy FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data

175
src/test/regress/expected/isolation_select_vs_all.out
View File

@ -55,8 +55,9 @@ id data int_data
1 b 1 1 b 1
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -138,8 +139,9 @@ id data int_data
3 d 3 3 d 3
4 e 4 4 e 4
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -161,8 +163,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -188,8 +191,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -219,8 +223,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -230,8 +235,9 @@ id data int_data id data int_d
3 d 3 3 d 3 3 d 3 3 d 3
4 e 4 4 e 4 4 e 4 4 e 4
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1555,8 +1561,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1579,8 +1586,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1603,8 +1611,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1627,8 +1636,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1651,8 +1661,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1676,8 +1687,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1699,8 +1711,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1729,8 +1742,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-ddl-create-index: CREATE INDEX select_append_index ON select_append(id); step s1-ddl-create-index: CREATE INDEX select_append_index ON select_append(id);
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1759,8 +1773,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1788,8 +1803,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1819,8 +1835,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-ddl-add-column: ALTER TABLE select_append ADD new_column int DEFAULT 0; step s1-ddl-add-column: ALTER TABLE select_append ADD new_column int DEFAULT 0;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data new_column id data int_data new_column id data int_data new_column id data int_data new_column
@ -1849,8 +1866,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1879,8 +1897,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1906,8 +1925,9 @@ create_distributed_table
step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV; step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b, 1 && echo 2, c, 2 && echo 3, d, 3 && echo 4, e, 4' WITH CSV;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1931,8 +1951,9 @@ step s1-drop: DROP TABLE select_append;
step s1-create-non-distributed-table: CREATE TABLE select_append(id integer, data text, int_data int); step s1-create-non-distributed-table: CREATE TABLE select_append(id integer, data text, int_data int);
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-task-tracker-select: step s1-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1954,8 +1975,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-insert: INSERT INTO select_append VALUES(0, 'k', 0); step s1-insert: INSERT INTO select_append VALUES(0, 'k', 0);
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -1978,8 +2000,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-insert-select: INSERT INTO select_append SELECT * FROM select_append; step s1-insert-select: INSERT INTO select_append SELECT * FROM select_append;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2002,8 +2025,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-update: UPDATE select_append SET data = 'l' WHERE id = 0; step s1-update: UPDATE select_append SET data = 'l' WHERE id = 0;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2026,8 +2050,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-delete: DELETE FROM select_append WHERE id = 1; step s1-delete: DELETE FROM select_append WHERE id = 1;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2050,8 +2075,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-truncate: TRUNCATE select_append; step s1-truncate: TRUNCATE select_append;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2070,8 +2096,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-drop: DROP TABLE select_append; step s1-drop: DROP TABLE select_append;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2087,8 +2114,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-ddl-create-index: CREATE INDEX select_append_index ON select_append(id); step s1-ddl-create-index: CREATE INDEX select_append_index ON select_append(id);
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2117,8 +2145,9 @@ step s1-ddl-create-index: CREATE INDEX select_append_index ON select_append(id);
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-ddl-drop-index: DROP INDEX select_append_index; step s1-ddl-drop-index: DROP INDEX select_append_index;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2147,8 +2176,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-ddl-add-column: ALTER TABLE select_append ADD new_column int DEFAULT 0; step s1-ddl-add-column: ALTER TABLE select_append ADD new_column int DEFAULT 0;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2178,8 +2208,9 @@ step s1-ddl-add-column: ALTER TABLE select_append ADD new_column int DEFAULT 0;
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-ddl-drop-column: ALTER TABLE select_append DROP new_column; step s1-ddl-drop-column: ALTER TABLE select_append DROP new_column;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2208,8 +2239,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-ddl-rename-column: ALTER TABLE select_append RENAME data TO new_column; step s1-ddl-rename-column: ALTER TABLE select_append RENAME data TO new_column;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
<waiting ...> <waiting ...>
step s1-commit: COMMIT; step s1-commit: COMMIT;
step s2-task-tracker-select: <... completed> step s2-task-tracker-select: <... completed>
@ -2241,8 +2273,9 @@ citus_total_relation_size
32768 32768
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2265,8 +2298,9 @@ step s1-initialize: COPY select_append FROM PROGRAM 'echo 0, a, 0 && echo 1, b,
step s1-begin: BEGIN; step s1-begin: BEGIN;
step s1-master-modify-multiple-shards: DELETE FROM select_append; step s1-master-modify-multiple-shards: DELETE FROM select_append;
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data
@ -2293,8 +2327,9 @@ create_distributed_table
step s2-task-tracker-select: step s2-task-tracker-select:
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
id data int_data id data int_data id data int_data id data int_data

2
src/test/regress/spec/isolation_append_copy_vs_all.spec
View File

@ -27,6 +27,7 @@ step "s1-real-time-select" { SELECT * FROM append_copy ORDER BY 1, 2; }
step "s1-task-tracker-select" step "s1-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s1-insert" { INSERT INTO append_copy VALUES(0, 'k', 0); } step "s1-insert" { INSERT INTO append_copy VALUES(0, 'k', 0); }
@ -60,6 +61,7 @@ step "s2-real-time-select" { SELECT * FROM append_copy ORDER BY 1, 2; }
step "s2-task-tracker-select" step "s2-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM append_copy AS t1 JOIN append_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s2-insert" { INSERT INTO append_copy VALUES(0, 'k', 0); } step "s2-insert" { INSERT INTO append_copy VALUES(0, 'k', 0); }

2
src/test/regress/spec/isolation_hash_copy_vs_all.spec
View File

@ -27,6 +27,7 @@ step "s1-real-time-select" { SELECT * FROM hash_copy ORDER BY 1, 2; }
step "s1-task-tracker-select" step "s1-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s1-insert" { INSERT INTO hash_copy VALUES(0, 'k', 0); } step "s1-insert" { INSERT INTO hash_copy VALUES(0, 'k', 0); }
@ -67,6 +68,7 @@ step "s2-real-time-select" { SELECT * FROM hash_copy ORDER BY 1, 2; }
step "s2-task-tracker-select" step "s2-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM hash_copy AS t1 JOIN hash_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s2-insert" { INSERT INTO hash_copy VALUES(0, 'k', 0); } step "s2-insert" { INSERT INTO hash_copy VALUES(0, 'k', 0); }

2
src/test/regress/spec/isolation_partitioned_copy_vs_all.spec
View File

@ -30,6 +30,7 @@ step "s1-real-time-select" { SELECT * FROM partitioned_copy ORDER BY 1, 2; }
step "s1-task-tracker-select" step "s1-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s1-insert" { INSERT INTO partitioned_copy VALUES(0, 'k', 0); } step "s1-insert" { INSERT INTO partitioned_copy VALUES(0, 'k', 0); }
@ -63,6 +64,7 @@ step "s2-real-time-select" { SELECT * FROM partitioned_copy ORDER BY 1, 2; }
step "s2-task-tracker-select" step "s2-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM partitioned_copy AS t1 JOIN partitioned_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s2-insert" { INSERT INTO partitioned_copy VALUES(0, 'k', 0); } step "s2-insert" { INSERT INTO partitioned_copy VALUES(0, 'k', 0); }

2
src/test/regress/spec/isolation_range_copy_vs_all.spec
View File

@ -27,6 +27,7 @@ step "s1-real-time-select" { SELECT * FROM range_copy ORDER BY 1, 2; }
step "s1-task-tracker-select" step "s1-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s1-insert" { INSERT INTO range_copy VALUES(0, 'k', 0); } step "s1-insert" { INSERT INTO range_copy VALUES(0, 'k', 0); }
@ -62,6 +63,7 @@ step "s2-real-time-select" { SELECT * FROM range_copy ORDER BY 1, 2; }
step "s2-task-tracker-select" step "s2-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM range_copy AS t1 JOIN range_copy AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s2-insert" { INSERT INTO range_copy VALUES(0, 'k', 0); } step "s2-insert" { INSERT INTO range_copy VALUES(0, 'k', 0); }

2
src/test/regress/spec/isolation_select_vs_all.spec
View File

@ -25,6 +25,7 @@ step "s1-real-time-select" { SELECT * FROM select_append ORDER BY 1, 2; }
step "s1-task-tracker-select" step "s1-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s1-insert" { INSERT INTO select_append VALUES(0, 'k', 0); } step "s1-insert" { INSERT INTO select_append VALUES(0, 'k', 0); }
@ -56,6 +57,7 @@ step "s2-real-time-select" { SELECT * FROM select_append ORDER BY 1, 2; }
step "s2-task-tracker-select" step "s2-task-tracker-select"
{ {
SET citus.task_executor_type TO "task-tracker"; SET citus.task_executor_type TO "task-tracker";
SET citus.enable_repartition_joins TO ON;
SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4; SELECT * FROM select_append AS t1 JOIN select_append AS t2 ON t1.id = t2.int_data ORDER BY 1, 2, 3, 4;
} }
step "s2-insert" { INSERT INTO select_append VALUES(0, 'k', 0); } step "s2-insert" { INSERT INTO select_append VALUES(0, 'k', 0); }