From 67020615303c9895bcf083acaddbd3e9e2244750 Mon Sep 17 00:00:00 2001 From: Halil Ozan Akgul Date: Mon, 27 Dec 2021 15:22:32 +0300 Subject: [PATCH] dnm3 --- src/test/regress/sql/multi_transaction_recovery.sql | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/regress/sql/multi_transaction_recovery.sql b/src/test/regress/sql/multi_transaction_recovery.sql index c29273a82..0a478fba5 100644 --- a/src/test/regress/sql/multi_transaction_recovery.sql +++ b/src/test/regress/sql/multi_transaction_recovery.sql @@ -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)