From b8df8c0cf6ae6c2bcd78ffd7d9bd629f51ab3bee Mon Sep 17 00:00:00 2001 From: Kyotaro Horiguchi Date: Mon, 8 Jun 2020 16:07:41 +0900 Subject: [PATCH] Signal notifications from logical replication workers Notifications need to be signaled to listeners but logical replication worker forgets to do that. Fix that by signaling notifications after committing a transaction. --- src/backend/replication/logical/worker.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index a752a1224d..28ae89c574 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -33,6 +33,7 @@ #include "catalog/pg_inherits.h" #include "catalog/pg_subscription.h" #include "catalog/pg_subscription_rel.h" +#include "commands/async.h" #include "commands/tablecmds.h" #include "commands/trigger.h" #include "executor/executor.h" @@ -517,6 +518,9 @@ apply_handle_commit(StringInfo s) pgstat_report_stat(false); store_flush_position(commit_data.end_lsn); + + /* Send out notify signals */ + ProcessCompletedNotifies(); } else { -- 2.18.2