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:06 UTC
[incubator-pegasus] 11/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 257287f44d8eed905e92850a40cb0f05138b7f3f
Author: jiashuo <js...@live.com>
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: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org