Worker节点崩溃后，如何终止Postgres Coordinator上无法停止的活跃查询？

解决方案 #

1. 移除故障Worker节点清理会话 #

Citus的节点管理工具可以直接处理Worker节点故障导致的僵死会话：

-- 移除故障Worker节点，Coordinator会自动清理依赖该节点的僵死查询
SELECT master_remove_node('故障Worker节点IP', 5432);

-- 会话清理完成后，若需要恢复节点可重新添加
SELECT master_add_node('故障Worker节点IP', 5432);

2. 给目标会话设置强制超时 #

通过会话级参数强制终止等待状态的查询：

-- 给目标会话设置1秒语句超时，触发自动终止
SET SESSION FOR 30334 statement_timeout = '1s';
-- 同时设置锁超时，避免锁等待阻塞
SET SESSION FOR 30334 lock_timeout = '1s';

3. 手动标记故障节点为不可用 #

更新Citus节点状态表，让Coordinator停止等待故障节点：

UPDATE pg_dist_node 
SET nodeisactive = false 
WHERE nodename = '故障Worker节点IP';

更新后Coordinator会放弃对该节点的请求，进而清理僵死会话。

4. 平滑重载PostgreSQL配置 #

使用smart模式重载配置，该模式会尝试清理僵死会话但不中断正常业务：

pg_ctl reload -D /你的PostgreSQL数据目录 -m smart

内容的提问来源于stack exchange，提问作者johnfensterman