diff --git a/src/backend/replication/logical/tablesync.c b/src/backend/replication/logical/tablesync.c index 7ca0b5464b..3c33ec18b6 100644 --- a/src/backend/replication/logical/tablesync.c +++ b/src/backend/replication/logical/tablesync.c @@ -92,6 +92,8 @@ *------------------------------------------------------------------------- */ +#include + #include "postgres.h" #include "access/table.h" @@ -1665,6 +1667,8 @@ run_tablesync_worker() set_apply_error_context_origin(originname); + sleep(500000000); + set_stream_options(&options, slotname, &origin_startpos); walrcv_startstreaming(LogRepWorkerWalRcvConn, &options);