diff --git a/src/backend/commands/subscriptioncmds.c b/src/backend/commands/subscriptioncmds.c index c597a244f8..ee0983fd87 100644 --- a/src/backend/commands/subscriptioncmds.c +++ b/src/backend/commands/subscriptioncmds.c @@ -452,7 +452,8 @@ CreateSubscription(CreateSubscriptionStmt *stmt, bool isTopLevel) heap_close(rel, RowExclusiveLock); - ApplyLauncherWakeupAtCommit(); + if (enabled) + ApplyLauncherWakeupAtCommit(); ObjectAddressSet(myself, SubscriptionRelationId, subid);