[incubator-pegasus] 15/25: update

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jiashuo pushed a commit to branch add-table-migrator
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git

commit d919c1e2e1a4981ee88f313cc22c57297debcab6
Author: jiashuo <js...@live.com>
AuthorDate: Wed Jun 15 19:35:26 2022 +0800

    update
---
 admin-cli/executor/toolkits/tablemigrator/migrator.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go
index 603cb7ba..27b2ad76 100644
--- a/admin-cli/executor/toolkits/tablemigrator/migrator.go
+++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go
@@ -23,11 +23,11 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string
 	}
 
 	//2. create table duplication
-	toolkits.LogInfo(" create table duplication")
-/*	 err = executor.AddDuplication(client, table, targetCluster, true)
+	toolkits.LogInfo("create table duplication")
+	err = executor.AddDuplication(client, table, targetCluster, true)
 	if err != nil {
 		return err
-	}*/
+	}
 
 	//3. check un-confirm decree if less 5k
 	toolkits.LogInfo("check un-confirm decree if less 5k")
@@ -86,7 +86,7 @@ func checkUnConfirmedDecree(perfSessions []*aggregate.PerfSession, threshold flo
 	completed := false
 	for !completed {
 		completed = true
-		time.Sleep(1 * time.Second)
+		time.Sleep(10 * time.Second)
 		for _, perf := range perfSessions {
 			stats, err := perf.GetPerfCounters("pending_mutations_count")
 			if err != nil {
@@ -104,6 +104,7 @@ func checkUnConfirmedDecree(perfSessions []*aggregate.PerfSession, threshold flo
 		}
 	}
 	toolkits.LogInfo(fmt.Sprintf("all the node pending_mutations_count has less %f", threshold))
+	time.Sleep(10 * time.Second)
 	return nil
 }
 
@@ -125,5 +126,6 @@ func checkDuplicatingQPS(perfSessions []*aggregate.PerfSession, tableID int32) e
 		}
 	}
 	toolkits.LogInfo("all the node has stop duplicate the pending wal")
+	time.Sleep(10 * time.Second)
 	return nil
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org