summaryrefslogtreecommitdiff
path: root/src/backend/replication/logical/worker.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/replication/logical/worker.c')
-rw-r--r--src/backend/replication/logical/worker.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index c9af775bc18..d77bb32bb9e 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -2368,7 +2368,7 @@ apply_dispatch(StringInfo s)
/*
* Set the current command being applied. Since this function can be
- * called recusively when applying spooled changes, save the current
+ * called recursively when applying spooled changes, save the current
* command.
*/
saved_command = apply_error_callback_arg.command;
@@ -2587,8 +2587,8 @@ LogicalRepApplyLoop(XLogRecPtr last_received)
pgstat_report_activity(STATE_IDLE, NULL);
/*
- * Push apply error context callback. Fields will be filled during
- * applying a change.
+ * Push apply error context callback. Fields will be filled while applying
+ * a change.
*/
errcallback.callback = apply_error_callback;
errcallback.previous = error_context_stack;
@@ -3608,7 +3608,7 @@ ApplyWorkerMain(Datum main_arg)
}
ereport(DEBUG1,
- (errmsg("logical replication apply worker for subscription \"%s\" two_phase is %s.",
+ (errmsg("logical replication apply worker for subscription \"%s\" two_phase is %s",
MySubscription->name,
MySubscription->twophasestate == LOGICALREP_TWOPHASE_STATE_DISABLED ? "DISABLED" :
MySubscription->twophasestate == LOGICALREP_TWOPHASE_STATE_PENDING ? "PENDING" :