fix clearing node events

hashicorp · Mar 14, 2018 · 4252ffe · 4252ffe
1 parent e83debc
commit 4252ffe
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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