From 94fd2cda96d91d939f82ba572713277af10e0f4b Mon Sep 17 00:00:00 2001 From: luancheng Date: Fri, 17 Jan 2020 13:41:53 +0800 Subject: [PATCH] restore: fix restore summary log --- pkg/restore/client.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/pkg/restore/client.go b/pkg/restore/client.go index 3030ba857..5e8df4418 100644 --- a/pkg/restore/client.go +++ b/pkg/restore/client.go @@ -242,8 +242,6 @@ func (rc *Client) RestoreTable( key := fmt.Sprintf("%s.%s", table.Db.Name.String(), table.Schema.Name.String()) if err != nil { summary.CollectFailureUnit(key, err) - } else { - summary.CollectSuccessUnit(key, elapsed) } }() @@ -342,6 +340,7 @@ func (rc *Client) RestoreAll( defer func() { elapsed := time.Since(start) log.Info("Restore All", zap.Duration("take", elapsed)) + summary.CollectSuccessUnit("restore all", elapsed) }() errCh := make(chan error, len(rc.databases)) wg := new(sync.WaitGroup)