Repository: ignite Updated Branches: refs/heads/ignite-8508 [created] 848a78668
IGNITE-8508 Use correct topology version for custom event ACK Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/848a7866 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/848a7866 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/848a7866 Branch: refs/heads/ignite-8508 Commit: 848a786683b1363223014cfe791b66e3fd05a640 Parents: 5f56879 Author: Alexey Goncharuk <[email protected]> Authored: Wed May 16 12:58:24 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed May 16 12:58:24 2018 +0300 ---------------------------------------------------------------------- .../spi/discovery/zk/internal/ZkDiscoveryEventsData.java | 11 +++++++++++ .../discovery/zk/internal/ZookeeperDiscoveryImpl.java | 2 +- 2 files changed, 12 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/848a7866/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkDiscoveryEventsData.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkDiscoveryEventsData.java b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkDiscoveryEventsData.java index dce861b..6520b8c 100644 --- a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkDiscoveryEventsData.java +++ b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZkDiscoveryEventsData.java @@ -21,6 +21,8 @@ import java.io.Serializable; import java.util.Collection; import java.util.TreeMap; import java.util.UUID; + +import org.apache.ignite.internal.util.typedef.internal.S; import org.jetbrains.annotations.Nullable; /** @@ -118,4 +120,13 @@ class ZkDiscoveryEventsData implements Serializable { evt.initRemainingAcks(nodes); } + + /** {@inheritDoc} */ + @Override public String toString() { + return S.toString(ZkDiscoveryEventsData.class, this, + "topVer", topVer, + "evtIdGen", evtIdGen, + "procCustEvt", procCustEvt, + "evts", evts); + } } http://git-wip-us.apache.org/repos/asf/ignite/blob/848a7866/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java index 0604458..43d6aeb 100644 --- a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java +++ b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoveryImpl.java @@ -3658,7 +3658,7 @@ public class ZookeeperDiscoveryImpl { ZkDiscoveryCustomEventData ackEvtData = new ZkDiscoveryCustomEventData( evtId, origEvt.eventId(), - origEvt.topologyVersion(), // Use topology version from original event. + rtState.evtsData.topVer, // Use actual topology version because topology version must be growing. locNode.id(), null, null);
