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

Fix worker node version check

pull/5816/head
Marco Slot 2022-03-16 22:09:22 +01:00 committed by Marco Slot
parent 22a18fc1f2
commit 5bb5359da0
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/sql/udfs/citus_finalize_upgrade_to_citus11/11.0-1.sql generated
View File

@ -117,10 +117,9 @@ END;
-- first, check if all nodes have the same versions
SELECT
count(*) INTO worker_node_version_count
count(distinct result) INTO worker_node_version_count
FROM
run_command_on_workers('SELECT extversion from pg_extension WHERE extname = ''citus'';')
GROUP BY result;
run_command_on_workers('SELECT extversion from pg_extension WHERE extname = ''citus''');
IF enforce_version_check AND worker_node_version_count != 1 THEN
RAISE EXCEPTION 'All nodes should have the same Citus version installed. Currently '
'some of the workers have different versions.';

5
src/backend/distributed/sql/udfs/citus_finalize_upgrade_to_citus11/latest.sql
View File

@ -117,10 +117,9 @@ END;
-- first, check if all nodes have the same versions
SELECT
count(*) INTO worker_node_version_count
count(distinct result) INTO worker_node_version_count
FROM
run_command_on_workers('SELECT extversion from pg_extension WHERE extname = ''citus'';')
GROUP BY result;
run_command_on_workers('SELECT extversion from pg_extension WHERE extname = ''citus''');
IF enforce_version_check AND worker_node_version_count != 1 THEN
RAISE EXCEPTION 'All nodes should have the same Citus version installed. Currently '
'some of the workers have different versions.';