ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-7871 Check local join future on error. - Fixes #3793.
Date Wed, 11 Apr 2018 15:52:05 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2.5 b6ad3705c -> e6c30e17c


IGNITE-7871 Check local join future on error. - Fixes #3793.

Signed-off-by: dpavlov <dpavlov@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e6c30e17
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e6c30e17
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e6c30e17

Branch: refs/heads/ignite-2.5
Commit: e6c30e17c6f0f1852fa781078ee54ccf8c654846
Parents: b6ad370
Author: Pavel Kovalenko <jokserfn@gmail.com>
Authored: Wed Apr 11 14:12:50 2018 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Wed Apr 11 18:51:52 2018 +0300

----------------------------------------------------------------------
 .../distributed/dht/preloader/latch/ExchangeLatchManager.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e6c30e17/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 c205cb1..404f88f 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
@@ -104,7 +104,8 @@ public class ExchangeLatchManager {
 
             // First coordinator initialization.
             ctx.discovery().localJoinFuture().listen(f -> {
-                this.coordinator = getLatchCoordinator(AffinityTopologyVersion.NONE);
+                if (f.error() == null)
+                    this.coordinator = getLatchCoordinator(AffinityTopologyVersion.NONE);
             });
 
             ctx.event().addDiscoveryEventListener((e, cache) -> {


Mime
View raw message