From 4252ffe71c32c58cec4aa61a28441511d39aa0fd Mon Sep 17 00:00:00 2001 From: Alex Dadgar Date: Wed, 14 Mar 2018 09:48:59 -0700 Subject: [PATCH] fix clearing node events --- client/client.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/client/client.go b/client/client.go index 06fc670c402..6d2f4d95c3e 100644 --- a/client/client.go +++ b/client/client.go @@ -1188,6 +1188,9 @@ func (c *Client) watchNodeEvents() { if err := c.submitNodeEvents(batchEvents); err != nil { c.logger.Printf("[ERR] client: submitting node events failed: %v", err) timer.Reset(c.retryIntv(nodeUpdateRetryIntv)) + } else { + // Reset the events since we succesfully sent them. + batchEvents = nil } case <-c.shutdownCh: return