alibaba/canal · error · ServiceException

当前集群下存在Server, 无法删除

Error message

当前集群下存在Server, 无法删除

What it means

Thrown by CanalClusterServiceImpl.delete(id) when NodeServer rows referencing clusterId still exist. The service refuses to delete a cluster that has attached servers to prevent orphaning.

Source

Thrown at admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/CanalClusterServiceImpl.java:34

public class CanalClusterServiceImpl implements CanalClusterService {

    public void save(CanalCluster canalCluster) {
        canalCluster.save();
    }

    public CanalCluster detail(Long id) {
        return CanalCluster.find.byId(id);
    }

    public void update(CanalCluster canalCluster) {
        canalCluster.update("name", "zkHosts");
    }

    public void delete(Long id) {
        // 判断集群下是否存在server信息
        int serverCnt = NodeServer.find.query().where().eq("clusterId", id).findCount();
        if (serverCnt > 0) {
            throw new ServiceException("当前集群下存在Server, 无法删除");
        }

        // 判断集群下是否存在instance信息
        int instanceCnt = CanalInstanceConfig.find.query().where().eq("clusterId", id).findCount();
        if (instanceCnt > 0) {
            throw new ServiceException("当前集群下存在Instance配置，无法删除");
        }

        CanalCluster canalCluster = CanalCluster.find.byId(id);
        if (canalCluster != null) {
            canalCluster.delete();
        }
    }

    public List<CanalCluster> findList(CanalCluster canalCluster) {
        Query<CanalCluster> query = CanalCluster.find.query();
        query.order().asc("id");
        return query.findList();

View on GitHub (pinned to 87be50e876)

Solutions

1. First delete or reassign all NodeServer entries whose clusterId points to this cluster.
2. Re-run the cluster delete after the server count for the cluster is zero.
3. If server records are stale/orphaned, clean them up via the node-server admin API.
4. Verify with: SELECT count(*) FROM node_server WHERE cluster_id = <id>.

int serverCnt = NodeServer.find.query().where().eq("clusterId", clusterId).findCount();
if (serverCnt > 0) {
    throw new IllegalStateException("Cannot delete cluster: " + serverCnt + " server(s) still attached");
}

When it happens

Trigger: DELETE a canal cluster (via the admin API/UI) while at least one NodeServer has clusterId == id. The pre-delete count check throws ServiceException with the Chinese message 'cluster has Server(s), cannot delete'.

Common situations: Attempting to remove a cluster before decommissioning its member servers; stale server records left after a server was removed improperly; UI bulk-delete ordering issue.

Related errors

• 当前集群下存在Instance配置，无法删除
• canal.adminUser is empty , pls check https://github.com/alib
• canal.adminPasswd is empty , pls check https://github.com/al
• unsupported version at this client.
• expect handshake but found other type.

AI-assisted analysis of alibaba/canal@87be50e876 (2026-08-14). Data as JSON: /api/errors/0641f52c585596cd. Report an issue: GitHub.