liuxiaolong
2020-05-14 9eb8adc39f97f167694128a18b896662715aa655
agent.go
@@ -445,7 +445,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) (*[]string, error) {
func (a *Agent) GetTableDataFromCluster(tableNames []string) (*string, error) {
   //members: get name of first member
   mbs := a.GroupMembers(a.conf.ClusterID)
   specmembername := ""
@@ -481,7 +481,7 @@
   var wg sync.WaitGroup
   wg.Add(1)
   var dumpSqls []string
   var dumpSqls string
   go func() {
      defer wg.Done()
      respCh := resp.ResponseCh()