mirror of
https://github.com/postgres/postgres.git
synced 2025-11-10 17:42:29 +03:00
@@ -575,7 +575,7 @@ check_relation_updatable(LogicalRepRelMapEntry *rel)
|
||||
ereport(ERROR,
|
||||
(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
|
||||
errmsg("logical replication target relation \"%s.%s\" has "
|
||||
"neither REPLICA IDENTIY index nor PRIMARY "
|
||||
"neither REPLICA IDENTITY index nor PRIMARY "
|
||||
"KEY and published relation does not have "
|
||||
"REPLICA IDENTITY FULL",
|
||||
rel->remoterel.nspname, rel->remoterel.relname)));
|
||||
|
||||
@@ -321,7 +321,7 @@ GetReplicationApplyDelay(void)
|
||||
long secs;
|
||||
int usecs;
|
||||
|
||||
TimestampTz chunckReplayStartTime;
|
||||
TimestampTz chunkReplayStartTime;
|
||||
|
||||
SpinLockAcquire(&walrcv->mutex);
|
||||
receivePtr = walrcv->receivedUpto;
|
||||
@@ -332,12 +332,12 @@ GetReplicationApplyDelay(void)
|
||||
if (receivePtr == replayPtr)
|
||||
return 0;
|
||||
|
||||
chunckReplayStartTime = GetCurrentChunkReplayStartTime();
|
||||
chunkReplayStartTime = GetCurrentChunkReplayStartTime();
|
||||
|
||||
if (chunckReplayStartTime == 0)
|
||||
if (chunkReplayStartTime == 0)
|
||||
return -1;
|
||||
|
||||
TimestampDifference(chunckReplayStartTime,
|
||||
TimestampDifference(chunkReplayStartTime,
|
||||
GetCurrentTimestamp(),
|
||||
&secs, &usecs);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user