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

dnm3

test-ozan2
Halil Ozan Akgul 2021-12-27 15:22:32 +03:00
parent 65655b3bfd
commit 6702061530
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/test/regress/sql/multi_transaction_recovery.sql
View File

@ -199,7 +199,7 @@ BEGIN;
SET LOCAL citus.defer_drop_after_shard_move TO OFF;
SELECT citus_move_shard_placement((SELECT * FROM selected_shard), 'localhost', :worker_1_port, 'localhost', :worker_2_port);
COMMIT;
SELECT COUNT(*) FROM pg_dist_transaction;
SELECT * FROM pg_dist_transaction;
SELECT recover_prepared_transactions();
SELECT citus_move_shard_placement((SELECT * FROM selected_shard), 'localhost', :worker_2_port, 'localhost', :worker_1_port);
@ -217,7 +217,7 @@ INSERT INTO test_2pcskip VALUES (7);
SELECT count(*) FROM test_2pcskip;
COMMIT;
SELECT count(*) FROM pg_dist_transaction;
SELECT * FROM pg_dist_transaction;
SELECT recover_prepared_transactions();
-- only two of the connections will perform a write (INSERT)