Repository: ignite Updated Branches: refs/heads/ignite-zk c8b8e430f -> 24a9078be
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/24a9078b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/24a9078b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/24a9078b Branch: refs/heads/ignite-zk Commit: 24a9078be0ca73a319d0b94615d00e5383966c90 Parents: c8b8e43 Author: sboikov <[email protected]> Authored: Tue Nov 28 14:51:56 2017 +0300 Committer: sboikov <[email protected]> Committed: Tue Nov 28 14:51:56 2017 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/24a9078b/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 38ed948..9122685 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 @@ -658,9 +658,9 @@ public class ZookeeperDiscoveryImpl { private void saveAndProcessNewEvents() throws Exception { long start = System.currentTimeMillis(); - byte [] evtsBytes = marsh.marshal(state.evtsData); + byte[] evtsBytes = U.zip(marshal(state.evtsData)); - state.zkClient.setData(zkPaths.evtsPath, marsh.marshal(state.evtsData), -1); + state.zkClient.setData(zkPaths.evtsPath, evtsBytes, -1); long time = System.currentTimeMillis() - start;
