cluster settings issue

housepower · Aug 25, 2024 · 70f742a · 70f742a
1 parent db6af9c
commit 70f742a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 16 deletions.
diff --git a/controller/clickhouse.go b/controller/clickhouse.go
@@ -3014,7 +3014,7 @@ func mergeClickhouseConfig(conf *model.CKManClickHouseConfig, force bool) (bool,
 	}
 
 	// need restart
-	if cluster.Port != conf.Port || storageChanged || expertChanged || keeperChanged {
+	if force || cluster.Port != conf.Port || storageChanged || expertChanged || keeperChanged {
 		restart = true
 	}
 

diff --git a/service/runner/handle.go b/service/runner/handle.go
@@ -322,21 +322,6 @@ func CKSettingHandle(task *model.Task) error {
 		return err
 	}
 
-	// sync table schema when logic cluster exists
-	deploy.SetNodeStatus(task, model.NodeStatusStore, model.ALL_NODES_DEFAULT)
-	if d.Conf.LogicCluster != nil {
-		logics, err := repository.Ps.GetLogicClusterbyName(*d.Conf.LogicCluster)
-		if err == nil && len(logics) > 0 {
-			for _, logic := range logics {
-				if cluster, err := repository.Ps.GetClusterbyName(logic); err == nil {
-					if clickhouse.SyncLogicTable(cluster, *d.Conf) {
-						break
-					}
-				}
-			}
-		}
-	}
-
 	if err := repository.Ps.Begin(); err != nil {
 		return errors.Wrapf(err, "[%s]", model.NodeStatusStore.EN)
 	}