serf/sync.go @@ -371,7 +371,7 @@ } func (ss *SyncServer) handleClusterMessage(msg []byte) { //fmt.Println("clusterMessage:", string(msg)) logx.Infof("clusterMessage:", string(msg)) sql := string(msg) if len(sql) <= 0 {