external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes errors in code

test_branch
gindibay 2023-07-28 19:26:25 +03:00
parent d42f5579ed
commit 4ed78f148e
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/test/regress/spec/isolation_citus_pause_node.spec
View File

@ -40,10 +40,6 @@ session "s1"
step "s1-begin" step "s1-begin"
{ {
BEGIN; BEGIN;
select * from pg_dist_node;
SELECT get_shard_id_for_distribution_column('employee', 3);
} }
step "s1-pause-node" step "s1-pause-node"
@ -57,10 +53,10 @@ step "s1-pause-node"
v_node_port int; v_node_port int;
BEGIN BEGIN
-- Get the shard id for the distribution column -- Get the shard id for the distribution column
SELECT get_shard_id_for_distribution_column('employee', 3) into shard_id; SELECT get_shard_id_for_distribution_column('employee', 3) into v_shard_id;
--Get the node id for the shard id --Get the node id for the shard id
SELECT nodename,nodeport into v_node_name,v_node_port FROM citus_shards WHERE shard_id = v_shard_id limit 1; SELECT nodename,nodeport into v_node_name,v_node_port FROM citus_shards WHERE shardid = v_shard_id limit 1;
raise notice 'node name is %',v_node_name; raise notice 'node name is %',v_node_name;
raise notice 'node port is %',v_node_port; raise notice 'node port is %',v_node_port;
@ -70,7 +66,7 @@ step "s1-pause-node"
-- Pause the node -- Pause the node
SELECT pg_catalog.citus_pause_node(v_node_id); perform pg_catalog.citus_pause_node(v_node_id) ;
END; END;
$$ $$
LANGUAGE plpgsql; LANGUAGE plpgsql;