Controller don't stop running watches on cluster resync (argoproj#1298)

tkasuz · Mar 19, 2019 · 80fe3e1 · 80fe3e1
1 parent 8f7a7ef
commit 80fe3e1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/controller/cache/cluster.go b/controller/cache/cluster.go
@@ -274,6 +274,9 @@ func (c *clusterInfo) sync() (err error) {
 
 	c.log.Info("Start syncing cluster")
 
+	for i := range c.apisMeta {
+		c.apisMeta[i].watchCancel()
+	}
 	c.apisMeta = make(map[schema.GroupKind]*apiMeta)
 	c.nodes = make(map[kube.ResourceKey]*node)