agent.go
@@ -417,7 +417,7 @@ //GetDbFromCluster get the newest database after join cluster //dbPathWrite the path where to write after got a database, func (a *Agent) GetTableDataFromCluster(tableNames []string) (*[]Rows,error) { func (a *Agent) GetTableDataFromCluster(tableNames []string) error { //members: get name of first member mbs := a.GroupMembers(a.conf.ClusterID) var specmembername string @@ -461,6 +461,7 @@ } } }() return nil //r, err = c.Query([]string{query}, false, false) //if err != nil {
