IGNITE-9501 Exclude newly joined nodes from exchange latch
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/371586ae Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/371586ae Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/371586ae Branch: refs/heads/ignite-10044 Commit: 371586ae7ceb941ba602a6ac2e8c3a313ab882d5 Parents: 0e34042 Author: Alexey Goncharuk <[email protected]> Authored: Wed Nov 28 18:57:48 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed Nov 28 18:57:48 2018 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/latch/ExchangeLatchManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/371586ae/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java index 35c04fb..0308ff4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java @@ -64,7 +64,7 @@ public class ExchangeLatchManager { * Exchange latch V2 protocol introduces following optimization: * Joining nodes are explicitly excluded from possible latch participants. */ - public static final IgniteProductVersion PROTOCOL_V2_VERSION_SINCE = IgniteProductVersion.fromString("2.7.0"); + public static final IgniteProductVersion PROTOCOL_V2_VERSION_SINCE = IgniteProductVersion.fromString("2.5.3"); /** Logger. */ private final IgniteLogger log;
