From 56ab57fe44f420d3c5969121f65c658fda733a64 Mon Sep 17 00:00:00 2001 From: onderkalaci Date: Thu, 4 May 2023 18:44:23 +0300 Subject: [PATCH] fix rebalancer to include passwork_required option Relevant PG commit: https://github.com/postgres/postgres/commit/c3afe8cf5a1e465bd71e48e4bc717f5bfdc7a7d6 c3afe8cf5a1e465bd71e48e4bc717f5bfdc7a7d6 --- .../distributed/replication/multi_logical_replication.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/backend/distributed/replication/multi_logical_replication.c b/src/backend/distributed/replication/multi_logical_replication.c index 550095875..1b7ab746b 100644 --- a/src/backend/distributed/replication/multi_logical_replication.c +++ b/src/backend/distributed/replication/multi_logical_replication.c @@ -1530,7 +1530,11 @@ CreateSubscriptions(MultiConnection *sourceConnection, appendStringInfo(createSubscriptionCommand, "CREATE SUBSCRIPTION %s CONNECTION %s PUBLICATION %s " "WITH (citus_use_authinfo=true, create_slot=false, " +#if PG_VERSION_NUM >= PG_VERSION_16 + "copy_data=false, enabled=false, slot_name=%s, password_required=false", +#else "copy_data=false, enabled=false, slot_name=%s", +#endif quote_identifier(target->subscriptionName), quote_literal_cstr(conninfo->data), quote_identifier(target->publication->name),