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 8e2f97da331f2b249301cc705e93d2fcaaef6d3f Author: jiashuo <[email protected]> AuthorDate: Thu Jun 16 15:19:02 2022 +0800 update postion --- admin-cli/executor/toolkits/tablemigrator/migrator.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go index c647fb5c..173ef5ca 100644 --- a/admin-cli/executor/toolkits/tablemigrator/migrator.go +++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go @@ -15,7 +15,7 @@ var pendingMutationThreshold = 100000.0 func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string, metaProxyZkRoot string, targetCluster string, targetAddrs string, threshold float64) error { pendingMutationThreshold = threshold - toolkits.LogInfo(fmt.Sprintf("set pendingMutationThreshold = %d means that server will reject all write " + + toolkits.LogInfo(fmt.Sprintf("set pendingMutationThreshold = %d means that server will reject all write "+ "and ready to switch cluster if the pending less the value", int64(pendingMutationThreshold))) //1. check data version toolkits.LogInfo("check data version") @@ -108,7 +108,7 @@ func checkUnConfirmedDecree(perfSessions map[string]*aggregate.PerfSession) erro } } } - toolkits.LogInfo(fmt.Sprintf("all the node pending_mutations_count has less %d", int64(pendingMutationThreshold))) + toolkits.LogInfo(fmt.Sprintf("all the node pending_mutations_count has less %d", int64(pendingMutationThreshold))) time.Sleep(10 * time.Second) return nil } @@ -130,7 +130,7 @@ func checkDuplicatingQPS(perfSessions map[string]*aggregate.PerfSession, tableID } } } - toolkits.LogInfo("all the node has stop duplicate the pending wal") - time.Sleep(10 * time.Second) + toolkits.LogInfo("all the node has stop duplicate the pending wal and wait 60s to switch cluster") + time.Sleep(60 * time.Second) return nil } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
