diff --git a/src/backend/commands/subscriptioncmds.c b/src/backend/commands/subscriptioncmds.c index 523959ba0ce..fd026b304c2 100644 --- a/src/backend/commands/subscriptioncmds.c +++ b/src/backend/commands/subscriptioncmds.c @@ -1748,9 +1748,11 @@ AlterSubscription(ParseState *pstate, AlterSubscriptionStmt *stmt, /* * Check if changes from different origins may be received * from the publisher when the origin is changed to ANY - * and retain_dead_tuples is enabled. + * and retain_dead_tuples is enabled. Use |= so that we + * don't clear the flag already set when + * retain_dead_tuples was changed in the same command. */ - check_pub_rdt = retain_dead_tuples && + check_pub_rdt |= retain_dead_tuples && pg_strcasecmp(opts.origin, LOGICALREP_ORIGIN_ANY) == 0; origin = opts.origin;