diff --git a/src/backend/commands/async.c b/src/backend/commands/async.c index 1f36bb72a8b..d1a174ff56e 100644 --- a/src/backend/commands/async.c +++ b/src/backend/commands/async.c @@ -1470,6 +1470,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 */ }