diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c index 68ab69fc294..efa2d111a61 100644 --- a/src/backend/commands/async.c +++ b/src/backend/commands/async.c @@ -1484,6 +1484,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 */ }