zk
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d175824b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d175824b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d175824b Branch: refs/heads/ignite-zk Commit: d175824b93899f9de2b21357b85f7814d94dce22 Parents: 36be0de Author: sboikov <[email protected]> Authored: Tue Nov 28 09:29:22 2017 +0300 Committer: sboikov <[email protected]> Committed: Tue Nov 28 09:29:22 2017 +0300 ---------------------------------------------------------------------- .../discovery/zk/internal/ZookeeperDiscoveryImpl.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d175824b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java index 76eb306..ba475ad 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java @@ -657,12 +657,17 @@ public class ZookeeperDiscoveryImpl { private void saveAndProcessNewEvents() throws Exception { long start = System.currentTimeMillis(); + byte [] evtsBytes = marsh.marshal(state.evtsData); + state.zkClient.setData(zkPaths.evtsPath, marsh.marshal(state.evtsData), -1); long time = System.currentTimeMillis() - start; - if (log.isInfoEnabled()) - log.info("Discovery coordinator saved new topology events [topVer=" + state.evtsData.topVer + ", saveTime=" + time + ']'); + if (log.isInfoEnabled()) { + log.info("Discovery coordinator saved new topology events [topVer=" + state.evtsData.topVer + + ", size=" + evtsBytes.length + + ", saveTime=" + time + ']'); + } processNewEvents(state.evtsData); } @@ -988,7 +993,7 @@ public class ZookeeperDiscoveryImpl { } else { if (log.isInfoEnabled()) - log.info("New discovery event data: " + evtData + ']'); + log.info("New discovery event data [evt=" + evtData + ", evtsHist=" + evts.size() + ']'); switch (evtData.eventType()) { case EventType.EVT_NODE_JOINED: {
