postgres
diff --git a/‎src/backend/replication/logical/reorderbuffer.c
Copy file name to clipboardExpand all lines: src/backend/replication/logical/reorderbuffer.c
+4Lines changed: 4 additions & 0 deletions b/‎src/backend/replication/logical/reorderbuffer.c
Copy file name to clipboardExpand all lines: src/backend/replication/logical/reorderbuffer.c
+4Lines changed: 4 additions & 0 deletions
@@ -2936,6 +2936,10 @@ ReorderBufferAbortOld(ReorderBuffer *rb, TransactionId oldestRunningXid)
 		{
 			elog(DEBUG2, "aborting old transaction %u", txn->xid);
 
+			/* Notify the remote node about the crash/immediate restart. */
+			if (rbtxn_is_streamed(txn))
+				rb->stream_abort(rb, txn, InvalidXLogRecPtr);
+
 			/* remove potential on-disk data, and deallocate this tx */
 			ReorderBufferCleanupTXN(rb, txn);
 		}
Original file line number	Diff line number	Diff line change
`@@ -2936,6 +2936,10 @@ ReorderBufferAbortOld(ReorderBuffer *rb, TransactionId oldestRunningXid)`
`2936`	`2936`	`{`
`2937`	`2937`	`elog(DEBUG2, "aborting old transaction %u", txn->xid);`
`2938`	`2938`
	`2939`	`+ /* Notify the remote node about the crash/immediate restart. */`
	`2940`	`+ if (rbtxn_is_streamed(txn))`
	`2941`	`+ rb->stream_abort(rb, txn, InvalidXLogRecPtr);`
	`2942`	`+`
`2939`	`2943`	`/* remove potential on-disk data, and deallocate this tx */`
`2940`	`2944`	`ReorderBufferCleanupTXN(rb, txn);`
`2941`	`2945`	`}`