diff options
| author | Peter Eisentraut <peter_e@gmx.net> | 2017-05-24 18:56:21 -0400 |
|---|---|---|
| committer | Peter Eisentraut <peter_e@gmx.net> | 2017-05-24 18:57:56 -0400 |
| commit | 92ecb148e517704ec945dce513db71fee7790cfd (patch) | |
| tree | f955f56a5ccfba9bd15a4d9d94622ea4073b86c9 /src/backend/replication/logical/tablesync.c | |
| parent | 85c2b9a15a1d667b1e2cd580da8c1d9fef0af1e8 (diff) | |
| download | postgresql-92ecb148e517704ec945dce513db71fee7790cfd.tar.gz postgresql-92ecb148e517704ec945dce513db71fee7790cfd.zip | |
Improve logical replication worker log messages
Reduce some redundant messages to DEBUG1. Be clearer about the
distinction between apply workers and table synchronization workers.
Add subscription and table name where possible.
Reviewed-by: Masahiko Sawada <sawada.mshk@gmail.com>
Diffstat (limited to 'src/backend/replication/logical/tablesync.c')
| -rw-r--r-- | src/backend/replication/logical/tablesync.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/backend/replication/logical/tablesync.c b/src/backend/replication/logical/tablesync.c index 1e3753b8fe2..d69fc7086d0 100644 --- a/src/backend/replication/logical/tablesync.c +++ b/src/backend/replication/logical/tablesync.c @@ -133,8 +133,11 @@ finish_sync_worker(void) /* Find the main apply worker and signal it. */ logicalrep_worker_wakeup(MyLogicalRepWorker->subid, InvalidOid); + StartTransactionCommand(); ereport(LOG, - (errmsg("logical replication synchronization worker finished processing"))); + (errmsg("logical replication table synchronization worker for subscription \"%s\", table \"%s\" has finished", + MySubscription->name, get_rel_name(MyLogicalRepWorker->relid)))); + CommitTransactionCommand(); /* Stop gracefully */ walrcv_disconnect(wrconn); |