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 08d00dce4d9a579669beb306346aceaec070e672 Author: jiashuo <[email protected]> AuthorDate: Wed Jun 15 19:12:16 2022 +0800 update --- admin-cli/executor/toolkits/tablemigrator/migrator.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go index ab7e5039..a536eb56 100644 --- a/admin-cli/executor/toolkits/tablemigrator/migrator.go +++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go @@ -31,6 +31,10 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string nodes := client.Nodes.GetAllNodes(session.NodeTypeReplica) var perfSessions []*aggregate.PerfSession for _, n := range nodes { + perf := client.Nodes.GetPerfSession(n.TCPAddr(), session.NodeTypeReplica) + if perf == nil { + return fmt.Errorf("get perf-node failed, node=%s", n.TCPAddr()) + } perfSessions = append(perfSessions, client.Nodes.GetPerfSession(n.TCPAddr(), session.NodeTypeReplica)) } err = checkUnConfirmedDecree(perfSessions, 5000) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
