From 3a0ab9b5997fb48d4bcae1f8377654f0e6d0fefd Mon Sep 17 00:00:00 2001 From: Jim Scott Date: Thu, 3 Nov 2016 11:39:12 -0700 Subject: [PATCH] Fixed type errors --- partitions.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/partitions.go b/partitions.go index c5ea7d64..2b62817f 100644 --- a/partitions.go +++ b/partitions.go @@ -132,10 +132,11 @@ func (p *partitions) updateRemotePartitions(nodes []string) { } // Keep track of old peers in case zookeeper goes away. - if len(p.old >= 1024) { + if len(p.old) >= 1024 { p.old = p.old[:1024] } - p.old = append(remote, p.old) + oldRemote := []map[int][]string{remote} + p.old = append(oldRemote, p.old...) p.remote = remote p.updateMissing() @@ -242,7 +243,8 @@ func (p *partitions) getPeers(partition int) []string { // Append old peers to peer list, in case of Zookeeper issues. for _, oldPeer := range p.old { - peers = append(peers, oldPeer[partition]) + + peers = append(peers, oldPeer[partition]...) } return peers }