mirror of https://github.com/citusdata/citus.git
fix rebalancer to include passwork_required option
Relevant PG commit:
c3afe8cf5a
c3afe8cf5a1e465bd71e48e4bc717f5bfdc7a7d6
naisila/user_arb_config
parent
fc454535be
commit
56ab57fe44
|
@ -1530,7 +1530,11 @@ CreateSubscriptions(MultiConnection *sourceConnection,
|
||||||
appendStringInfo(createSubscriptionCommand,
|
appendStringInfo(createSubscriptionCommand,
|
||||||
"CREATE SUBSCRIPTION %s CONNECTION %s PUBLICATION %s "
|
"CREATE SUBSCRIPTION %s CONNECTION %s PUBLICATION %s "
|
||||||
"WITH (citus_use_authinfo=true, create_slot=false, "
|
"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",
|
"copy_data=false, enabled=false, slot_name=%s",
|
||||||
|
#endif
|
||||||
quote_identifier(target->subscriptionName),
|
quote_identifier(target->subscriptionName),
|
||||||
quote_literal_cstr(conninfo->data),
|
quote_literal_cstr(conninfo->data),
|
||||||
quote_identifier(target->publication->name),
|
quote_identifier(target->publication->name),
|
||||||
|
|
Loading…
Reference in New Issue