diff --git a/src/backend/replication/walreceiver.c b/src/backend/replication/walreceiver.c index 05445dc4f40..a6f85108b97 100644 --- a/src/backend/replication/walreceiver.c +++ b/src/backend/replication/walreceiver.c @@ -1003,6 +1003,13 @@ XLogWalRcvFlush(bool dying, TimeLineID tli) { Assert(tli != 0); + if (dying) + { + ereport(LOG, + (errmsg("stop streaming WAL from primary at %X/%X on timeline %u", + LSN_FORMAT_ARGS(LogstreamResult.Write), tli))); + } + if (LogstreamResult.Flush < LogstreamResult.Write) { WalRcvData *walrcv = WalRcv;