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:08 UTC
[incubator-pegasus] 13/25: update
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 fdd277c037a68e4f7a31ca3623f3c2e497074357
Author: jiashuo <js...@live.com>
AuthorDate: Wed Jun 15 19:32:12 2022 +0800
update
---
admin-cli/executor/toolkits/tablemigrator/migrator.go | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go
index bfb66bf0..e1c6b20a 100644
--- a/admin-cli/executor/toolkits/tablemigrator/migrator.go
+++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go
@@ -13,6 +13,7 @@ import (
func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string, metaProxyZkRoot string, targetCluster string, targetAddrs string) error {
//1. check data version
+ toolkits.LogDebug("check data version")
version, err := executor.QueryReplicaDataVersion(client, table)
if err != nil {
return err
@@ -22,12 +23,14 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string
}
//2. create table duplication
- /** err = executor.AddDuplication(client, table, targetCluster, true)
+ toolkits.LogDebug(" create table duplication")
+/* err = executor.AddDuplication(client, table, targetCluster, true)
if err != nil {
return err
- }**/
+ }*/
//3. check un-confirm decree if less 5k
+ toolkits.LogDebug("check un-confirm decree if less 5k")
nodes := client.Nodes.GetAllNodes(session.NodeTypeReplica)
var perfSessions []*aggregate.PerfSession
for _, n := range nodes {
@@ -48,6 +51,7 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string
return err
}
//4. set env config deny write request
+ toolkits.LogDebug("set env config deny write request")
var envs = map[string]string{
"replica.deny_client_request": "timeout*write",
}
@@ -56,6 +60,7 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string
return err
}
//5. check duplicate qps if equal 0
+ toolkits.LogDebug("check duplicate qps if equal 0")
resp, err := client.Meta.QueryConfig(table)
if err != nil {
return err
@@ -65,6 +70,7 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string
return err
}
//6. switch table addrs in metaproxy
+ toolkits.LogDebug("switch table addrs in metaproxy")
if metaProxyZkRoot == "" {
toolkits.LogWarn("you don't specify enough meta proxy info, please manual-switch the table cluster!")
return nil
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org