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:19 UTC
[incubator-pegasus] 24/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 dc9f8efa0b5845d5f431869781b631f601205d6b
Author: jiashuo <js...@live.com>
AuthorDate: Thu Jun 16 15:23:55 2022 +0800
update postion
---
admin-cli/executor/toolkits/tablemigrator/migrator.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go
index 21bdc38b..aa40eaaf 100644
--- a/admin-cli/executor/toolkits/tablemigrator/migrator.go
+++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go
@@ -103,7 +103,7 @@ func checkUnConfirmedDecree(perfSessions map[string]*aggregate.PerfSession) erro
if stats[0].Value > pendingMutationThreshold {
completed = false
- toolkits.LogInfo(fmt.Sprintf("%s has pending_mutations_count %d", addr, int64(stats[0].Value)))
+ toolkits.LogWarn(fmt.Sprintf("%s has pending_mutations_count %d", addr, int64(stats[0].Value)))
break
}
}
@@ -124,7 +124,7 @@ func checkDuplicatingQPS(perfSessions map[string]*aggregate.PerfSession, tableID
for gpid, qps := range stats {
if qps > 0 {
completed = false
- toolkits.LogInfo(fmt.Sprintf("%s[%s] still sending pending mutation %d", addr, gpid, int64(qps)))
+ toolkits.LogWarn(fmt.Sprintf("%s[%s] still sending pending mutation %d", addr, gpid, int64(qps)))
break
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org