diff --git a/src/backend/executor/execReplication.c b/src/backend/executor/execReplication.c index bef40b30c9e..f18c9a82a9e 100644 --- a/src/backend/executor/execReplication.c +++ b/src/backend/executor/execReplication.c @@ -320,6 +320,9 @@ retry: XactLockTableWait(xwait, NULL, NULL, XLTW_None); goto retry; } + + /* Found our tuple and it's not locked */ + break; } /* Found tuple, try to lock it in the lockmode. */