Merge pull request #993 from andyxning/fix_full_topic_sync_accumulation

nsqd: fix full topic sync accumulation
nsqio · Mar 3, 2018 · 1587161 · 1587161
2 parents e6debab + 67d70f8
commit 1587161
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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(LOG_ERROR, "LOOKUPD(%s): %s - %s", lp, cmd, err)
+			return
 		} else if bytes.Equal(resp, []byte("E_INVALID")) {
 			n.logf(LOG_INFO, "LOOKUPD(%s): lookupd returned %s", lp, resp)
 		} else {