pgsql: Don't advance origin during apply failure. - Mailing list pgsql-committers

From Amit Kapila
Subject pgsql: Don't advance origin during apply failure.
Date
Msg-id E1vYGm6-002MTK-0Q@gemulon.postgresql.org
Whole thread Raw
List pgsql-committers
Don't advance origin during apply failure.

The logical replication parallel apply worker could incorrectly advance
the origin progress during an error or failed apply. This behavior risks
transaction loss because such transactions will not be resent by the
server.

Commit 3f28b2fcac addressed a similar issue for both the apply worker and
the table sync worker by registering a before_shmem_exit callback to reset
origin information. This prevents the worker from advancing the origin
during transaction abortion on shutdown. This patch applies the same fix
to the parallel apply worker, ensuring consistent behavior across all
worker types.

As with 3f28b2fcac, we are backpatching through version 16, since parallel
apply mode was introduced there and the issue only occurs when changes are
applied before the transaction end record (COMMIT or ABORT) is received.

Author: Hou Zhijie <houzj.fnst@fujitsu.com>
Reviewed-by: Chao Li <li.evan.chao@gmail.com>
Reviewed-by: Amit Kapila <amit.kapila16@gmail.com>
Backpatch-through: 16
Discussion: https://postgr.es/m/TY4PR01MB169078771FB31B395AB496A6B94B4A@TY4PR01MB16907.jpnprd01.prod.outlook.com
Discussion: https://postgr.es/m/TYAPR01MB5692FAC23BE40C69DA8ED4AFF5B92@TYAPR01MB5692.jpnprd01.prod.outlook.com

Branch
------
REL_17_STABLE

Details
-------
https://git.postgresql.org/pg/commitdiff/0ed8f1afb15f5913458b0363c0eb818e758f97bd

Modified Files
--------------
src/backend/replication/logical/worker.c       | 30 +++++++++--------
src/test/subscription/t/023_twophase_stream.pl | 45 ++++++++++++++++++++++++++
2 files changed, 62 insertions(+), 13 deletions(-)


pgsql-committers by date:

Previous
From: Tom Lane
Date:
Subject: pgsql: Fix another case of indirectly casting away const.
Next
From: Michael Paquier
Date:
Subject: pgsql: Improve comment in pgstatfuncs.c