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