Parsed test spec with 2 sessions starting permutation: s1-begin s1-update-node-1 s2-update-node-2 s1-commit s1-show-nodes nodeid|nodename |nodeport --------------------------------------------------------------------- 22|localhost| 57638 21|localhost| 57637 (2 rows) step s1-begin: BEGIN; step s1-update-node-1: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'localhost', 58637); ?column? --------------------------------------------------------------------- 1 (1 row) step s2-update-node-2: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57638), 'localhost', 58638); step s1-commit: COMMIT; step s2-update-node-2: <... completed> ?column? --------------------------------------------------------------------- 1 (1 row) step s1-show-nodes: SELECT nodeid, nodename, nodeport, isactive FROM pg_dist_node ORDER BY nodename, nodeport; nodeid|nodename |nodeport|isactive --------------------------------------------------------------------- 21|localhost| 58637|t 22|localhost| 58638|t (2 rows) nodeid|nodename|nodeport --------------------------------------------------------------------- (0 rows) starting permutation: s1-begin s1-update-node-1 s2-begin s2-update-node-1 s1-commit s2-abort s1-show-nodes nodeid|nodename |nodeport --------------------------------------------------------------------- 24|localhost| 57638 23|localhost| 57637 (2 rows) step s1-begin: BEGIN; step s1-update-node-1: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'localhost', 58637); ?column? --------------------------------------------------------------------- 1 (1 row) step s2-begin: BEGIN; step s2-update-node-1: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'localhost', 58637); step s1-commit: COMMIT; step s2-update-node-1: <... completed> ?column? --------------------------------------------------------------------- 1 (1 row) step s2-abort: ABORT; step s1-show-nodes: SELECT nodeid, nodename, nodeport, isactive FROM pg_dist_node ORDER BY nodename, nodeport; nodeid|nodename |nodeport|isactive --------------------------------------------------------------------- 24|localhost| 57638|t 23|localhost| 58637|t (2 rows) nodeid|nodename|nodeport --------------------------------------------------------------------- (0 rows) starting permutation: s1-begin s1-update-node-1 s2-start-metadata-sync-node-2 s1-commit s2-verify-metadata nodeid|nodename |nodeport --------------------------------------------------------------------- 26|localhost| 57638 25|localhost| 57637 (2 rows) step s1-begin: BEGIN; step s1-update-node-1: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'localhost', 58637); ?column? --------------------------------------------------------------------- 1 (1 row) step s2-start-metadata-sync-node-2: SELECT start_metadata_sync_to_node('localhost', 57638); step s1-commit: COMMIT; step s2-start-metadata-sync-node-2: <... completed> start_metadata_sync_to_node --------------------------------------------------------------------- (1 row) step s2-verify-metadata: SELECT nodeid, groupid, nodename, nodeport FROM pg_dist_node ORDER BY nodeid; SELECT master_run_on_worker( ARRAY['localhost'], ARRAY[57638], ARRAY['SELECT jsonb_agg(ROW(nodeid, groupid, nodename, nodeport) ORDER BY nodeid) FROM pg_dist_node'], false); nodeid|groupid|nodename |nodeport --------------------------------------------------------------------- 25| 25|localhost| 58637 26| 26|localhost| 57638 (2 rows) master_run_on_worker --------------------------------------------------------------------- (localhost,57638,t,"[{""f1"": 10, ""f2"": 10, ""f3"": ""localhost"", ""f4"": 57638}]") (1 row) nodeid|nodename|nodeport --------------------------------------------------------------------- (0 rows) starting permutation: s2-create-table s1-begin s1-update-node-nonexistent s1-prepare-transaction s2-cache-prepared-statement s1-commit-prepared s2-execute-prepared s1-update-node-existent s2-drop-table nodeid|nodename |nodeport --------------------------------------------------------------------- 28|localhost| 57638 27|localhost| 57637 (2 rows) step s2-create-table: CREATE TABLE test (a int); SELECT create_distributed_table('test','a'); create_distributed_table --------------------------------------------------------------------- (1 row) step s1-begin: BEGIN; step s1-update-node-nonexistent: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'non-existent', 57637); ?column? --------------------------------------------------------------------- 1 (1 row) step s1-prepare-transaction: PREPARE transaction 'label'; step s2-cache-prepared-statement: PREPARE foo AS SELECT COUNT(*) FROM test WHERE a = 3; EXECUTE foo; EXECUTE foo; EXECUTE foo; EXECUTE foo; EXECUTE foo; EXECUTE foo; count --------------------------------------------------------------------- 0 (1 row) count --------------------------------------------------------------------- 0 (1 row) count --------------------------------------------------------------------- 0 (1 row) count --------------------------------------------------------------------- 0 (1 row) count --------------------------------------------------------------------- 0 (1 row) count --------------------------------------------------------------------- 0 (1 row) step s1-commit-prepared: COMMIT prepared 'label'; s2: WARNING: connection to the remote node non-existent:57637 failed with the following error: could not translate host name "non-existent" to address: Name or service not known step s2-execute-prepared: EXECUTE foo; count --------------------------------------------------------------------- 0 (1 row) step s1-update-node-existent: SELECT 1 FROM master_update_node( (select nodeid from pg_dist_node where nodeport = 57637), 'localhost', 57637); ?column? --------------------------------------------------------------------- 1 (1 row) step s2-drop-table: DROP TABLE test; nodeid|nodename|nodeport --------------------------------------------------------------------- (0 rows)