You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by ji...@apache.org on 2022/06/16 07:34:17 UTC
[incubator-pegasus] 22/25: update postion
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 <js...@live.com>
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: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org