zk
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/775a60f7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/775a60f7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/775a60f7 Branch: refs/heads/ignite-zk Commit: 775a60f79904686b2e443789ae8c62df74f4d6fa Parents: d2f5a76 Author: sboikov <sboi...@gridgain.com> Authored: Tue Nov 14 17:36:24 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Nov 14 17:36:24 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/775a60f7/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java index 4adb427..d27987b 100644 --- a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java +++ b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java @@ -939,6 +939,7 @@ public class ZookeeperDiscoverySpi extends IgniteSpiAdapter implements Discovery } try { + // TODO ZK: handle case if node exists after crd change. for (ZKDiscoveryEvent evt : evts.values()) zkCurator.create().withMode(CreateMode.PERSISTENT).forPath(DISCO_EVTS_HIST_PATH + "/" + evt.topVer, marshal(evt)); } @@ -969,6 +970,7 @@ public class ZookeeperDiscoverySpi extends IgniteSpiAdapter implements Discovery /** */ private ZKDiscoveryEvent lastEvt; + /** */ private int lastProcessed = -1; /** @@ -1144,6 +1146,9 @@ public class ZookeeperDiscoverySpi extends IgniteSpiAdapter implements Discovery this.nextJoinOrder = nextJoinOrder; this.aliveNodes = aliveNodes; this.evts = evts; + + while (evts.size() > 1000) + evts.remove(evts.first()); } /** {@inheritDoc} */
