From 9c0bd91b02979864a4a4f19e475b97587e1b9635 Mon Sep 17 00:00:00 2001 From: Andy Xie Date: Tue, 6 Feb 2018 14:43:04 +0800 Subject: [PATCH] fix full topic sync accumjulation --- nsqd/lookup.go | 1 + 1 file changed, 1 insertion(+) diff --git a/nsqd/lookup.go b/nsqd/lookup.go index d0242e8aa..79761128f 100644 --- a/nsqd/lookup.go +++ b/nsqd/lookup.go @@ -29,6 +29,7 @@ func connectCallback(n *NSQD, hostname string, syncTopicChan chan *lookupPeer) f resp, err := lp.Command(cmd) if err != nil { n.logf("LOOKUPD(%s): ERROR %s - %s", lp, cmd, err) + return } else if bytes.Equal(resp, []byte("E_INVALID")) { n.logf("LOOKUPD(%s): lookupd returned %s", lp, resp) } else {