Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit82a0ba7

Browse files
author
Amit Kapila
committed
Fix the logical streaming test.
Commit7259736 added the capability to stream changes in ReorderBufferwhich has some tests to test the streaming mode. It is quite possible thatwhile this test is running a parallel transaction could be logged byautovacuum. Such a transaction won't perform any insert/update/delete tonon-catalog tables so will be shown as an empty transaction. Fix it byskipping the empty transactions during this test.Per report by buildfarm.
1 parenta13421c commit82a0ba7

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

‎contrib/test_decoding/expected/stream.out

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ TRUNCATE table stream_test;
2626
rollback to s1;
2727
INSERT INTO stream_test SELECT repeat('a', 10) || g.i FROM generate_series(1, 20) g(i);
2828
COMMIT;
29-
SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL,NULL, 'include-xids', '0', 'stream-changes', '1');
29+
SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL,NULL, 'include-xids', '0', 'skip-empty-xacts', '1', 'stream-changes', '1');
3030
data
3131
----------------------------------------------------------
3232
opening a streamed block for transaction
@@ -67,7 +67,7 @@ SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL, 'inc
6767
(0 rows)
6868

6969
INSERT INTO stream_test SELECT repeat('a', 6000) || g.i FROM generate_series(1, 10) g(i);
70-
SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL,NULL, 'include-xids', '0', 'stream-changes', '1');
70+
SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL,NULL, 'include-xids', '0', 'skip-empty-xacts', '1', 'stream-changes', '1');
7171
data
7272
------------------------------------------
7373
opening a streamed block for transaction

‎contrib/test_decoding/sql/stream.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,15 +16,15 @@ rollback to s1;
1616
INSERT INTO stream_testSELECT repeat('a',10)||g.iFROM generate_series(1,20) g(i);
1717
COMMIT;
1818

19-
SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','stream-changes','1');
19+
SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','stream-changes','1');
2020

2121
-- streaming test for toast changes
2222
ALTERTABLE stream_test ALTER COLUMN dataset storage external;
2323
-- consume DDL
2424
SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1');
2525

2626
INSERT INTO stream_testSELECT repeat('a',6000)||g.iFROM generate_series(1,10) g(i);
27-
SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','stream-changes','1');
27+
SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','stream-changes','1');
2828

2929
DROPTABLE stream_test;
3030
SELECT pg_drop_replication_slot('regression_slot');

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp