diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c index 7b774cc5e51..e1cf659485a 100644 --- a/src/backend/commands/async.c +++ b/src/backend/commands/async.c @@ -1418,6 +1418,7 @@ asyncQueueAddEntries(ListCell *nextNotify) */ qe.length = QUEUE_PAGESIZE - offset; qe.dboid = InvalidOid; + qe.xid = InvalidTransactionId; qe.data[0] = '\0'; /* empty channel */ qe.data[1] = '\0'; /* empty payload */ }