diff --git a/src/bin/pg_probackup/backup.cpp b/src/bin/pg_probackup/backup.cpp index 0ed9e774e..5ac9a924d 100644 --- a/src/bin/pg_probackup/backup.cpp +++ b/src/bin/pg_probackup/backup.cpp @@ -1223,10 +1223,20 @@ void tryToFindCompressedWALFile(bool *file_exists, char *gz_wal_segment_path, ch #ifdef HAVE_LIBZ *file_exists = fileExists(gz_wal_segment_path, FIO_BACKUP_HOST); if (*file_exists) + { elog(LOG, "Found compressed WAL segment: %s", wal_segment_path); + if (current.from_replica) + { + elog(INFO, "Wait a few minutes to get the target LSN or the last valid record prior to the target LSN"); + } + } #endif } else { elog(LOG, "Found WAL segment: %s", wal_segment_path); + if (current.from_replica) + { + elog(INFO, "Wait a few minutes to get the target LSN or the last valid record prior to the target LSN"); + } } } diff --git a/src/bin/pg_probackup/parsexlog.cpp b/src/bin/pg_probackup/parsexlog.cpp index ae4ee2b63..644ee5f13 100644 --- a/src/bin/pg_probackup/parsexlog.cpp +++ b/src/bin/pg_probackup/parsexlog.cpp @@ -1054,8 +1054,9 @@ static int switch_next_wal_segment(XLogReaderData *reader_data, bool *isreturn) if (fileExists(reader_data->xlogpath, FIO_LOCAL_HOST)) { - elog(LOG, "Thread [%d]: Opening WAL segment \"%s\"", - reader_data->thread_num, reader_data->xlogpath); + if (!current.from_replica) + elog(LOG, "Thread [%d]: Opening WAL segment \"%s\"", + reader_data->thread_num, reader_data->xlogpath); reader_data->xlogexists = true; reader_data->xlogfile = fio_open(reader_data->xlogpath,