SymmetricDS三层数据同步：BO节点initial_load_end_time为空致下游注册失败求助

问题背景 #

搭建了CI→BO→Till三层数据流，CI到BO的数据同步已完成，CI服务器日志显示BO节点初始加载结束，但BO数据库的sym_node_security表中，node_id为1112100的initial_load_end_time字段为空：

"node_id"   "initial_load_time"         "initial_load_end_time"
"1000000"   "2025-06-18 11:16:58.698"   "2025-06-18 11:16:58.698"
"1112100"   "2025-06-18 11:19:29.384"   "[null]"

这导致Till节点启动时无法注册，报错：

[store] - RegistrationService - Cannot register a client node until this node has an initial load (ie. node_security.initial_load_end_time is a non null value)
[store] - RegistrationUriHandler - till:22:? was not allowed to register.

临时通过手动执行SQL修复：

update sym_node_security
set initial_load_end_time = current_timestamp
where node_id = '1112100';

但需要实现该字段在CI完成BO初始加载后自动赋值，无需手动操作。

根源分析与永久解决方案 #

1. 先确认初始加载是否真的完整完成 #

查看BO节点的SymmetricDS日志（默认路径logs/symmetric.log），搜索initial load completed关键字：

• 如果没有找到该日志，说明初始加载过程中存在隐性错误（比如表结构不匹配、数据权限不足、同步中断），需要排查日志中的报错信息，修复后重新触发初始加载。
• 如果能找到完成日志，说明SymmetricDS未自动触发initial_load_end_time的更新，属于配置或版本问题。

2. 配置自动更新逻辑 #

方案A：利用SymmetricDS自身的事件触发

在CI节点添加触发器和路由规则，让初始加载完成后自动同步更新BO节点的sym_node_security表：

1. 创建触发器监听sym_node_security的变化：

INSERT INTO sym_trigger (trigger_id, source_table_name, channel_id, sync_on_insert, sync_on_update, sync_on_delete)
VALUES ('INIT_LOAD_END_TRIGGER', 'sym_node_security', 'default', 1, 1, 0);

2. 添加路由规则，将CI节点的sym_node_security更新同步到BO节点组：

INSERT INTO sym_router (router_id, source_node_group_id, target_node_group_id, trigger_id, router_type)
VALUES ('INIT_LOAD_END_ROUTER', 'CI', 'BO', 'INIT_LOAD_END_TRIGGER', 'default');

3. 重新触发CI到BO的初始加载，验证initial_load_end_time是否自动赋值。

方案B：在BO节点创建数据库触发器

直接在BO数据库中创建触发器，当initial_load_time存在但initial_load_end_time为空时，自动填充当前时间：

-- PostgreSQL版本
CREATE TRIGGER trg_auto_set_load_end_time
AFTER UPDATE ON sym_node_security
FOR EACH ROW
WHEN (NEW.initial_load_time IS NOT NULL AND NEW.initial_load_end_time IS NULL)
EXECUTE FUNCTION (
    UPDATE sym_node_security
    SET initial_load_end_time = CURRENT_TIMESTAMP
    WHERE node_id = NEW.node_id
);

-- MySQL版本
DELIMITER //
CREATE TRIGGER trg_auto_set_load_end_time
AFTER UPDATE ON sym_node_security
FOR EACH ROW
BEGIN
    IF NEW.initial_load_time IS NOT NULL AND NEW.initial_load_end_time IS NULL THEN
        UPDATE sym_node_security
        SET initial_load_end_time = CURRENT_TIMESTAMP
        WHERE node_id = NEW.node_id;
    END IF;
END //
DELIMITER ;

3. 检查版本兼容性 #

如果使用的SymmetricDS版本较旧（比如3.10以下），可能存在三层拓扑下初始加载状态未正确更新的已知问题，建议升级到最新稳定版本（如3.12.x系列），并重新配置同步规则。

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