@@ -294,7 +294,7 @@ BEGIN
294
294
rm_node_id, node .id ,
295
295
node .id , rm_node_id,
296
296
rm_node_id, node .id );
297
- -- Subscription with associated slot can not be droped inside block, but if we do not override syncronous_commit policy,
297
+ -- Subscription with associated slot can not be dropped inside block, but if we do not override synchronous_commit policy,
298
298
-- then this command will be blocked waiting for sync replicas. So we need first do unbound slot from subscription.
299
299
-- But it is possible only for disabled subscriptions. So we have to perform three steps: disable subscription, unbound slot, drop subscription.
300
300
alts := format(' %s{%s:ALTER SUBSCRIPTION sub_%s_%s DISABLE;ALTER SUBSCRIPTION sub_%s_%s SET (slot_name=NONE)}{%s:ALTER SUBSCRIPTION sub_%s_%s DISABLE;ALTER SUBSCRIPTION sub_%s_%s SET (slot_name=NONE)}' ,
@@ -860,7 +860,7 @@ DECLARE
860
860
src text ;
861
861
new_master bool;
862
862
BEGIN
863
- -- Check if valid node ID is passed and get connectoin string for this node
863
+ -- Check if valid node ID is passed and get connection string for this node
864
864
SELECT connection_string INTO conn_string FROM shardman .nodes WHERE id= master_node_id;
865
865
IF conn_string IS NULL THEN
866
866
RAISE EXCEPTION ' There is no node with ID % in the cluster' , master_node_id;
@@ -952,7 +952,7 @@ $$ LANGUAGE plpgsql;
952
952
953
953
-- Move replica to other node. This function is able to move replica only within replication group.
954
954
-- It initiates copying data to new replica, disables logical replication to original replica,
955
- -- waits completion of initial table sync and then removes old replca .
955
+ -- waits completion of initial table sync and then removes old replica .
956
956
CREATE FUNCTION mv_replica (mv_part_name text , src_node_id int , dst_node_id int )
957
957
RETURNS void AS $$
958
958
DECLARE
@@ -1290,6 +1290,6 @@ $$ LANGUAGE plpgsql;
1290
1290
1291
1291
CREATE FUNCTION deny_access () RETURNS trigger AS $$
1292
1292
BEGIN
1293
- RAISE EXCEPTION ' Access to moving parition is temporary denied' ;
1293
+ RAISE EXCEPTION ' Access to moving partition is temporary denied' ;
1294
1294
END
1295
1295
$$ LANGUAGE plpgsql;
0 commit comments