ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a.@apache.org
Subject [1/2] ignite git commit: IGNITE-4242 ExchangeManager should wait for cache rebalancing in async way
Date Mon, 21 Nov 2016 20:27:03 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-4242 787236a15 -> 2d54d274a


IGNITE-4242 ExchangeManager should wait for cache rebalancing in async way


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

Branch: refs/heads/ignite-4242
Commit: 00861223101147dd3ecb60bec552bb06e226fd98
Parents: 787236a
Author: Anton Vinogradov <av@apache.org>
Authored: Mon Nov 21 22:20:04 2016 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Mon Nov 21 22:20:04 2016 +0300

----------------------------------------------------------------------
 .../distributed/dht/preloader/GridDhtPartitionDemander.java     | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/00861223/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
index 999f99c..41b7bc1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
@@ -292,6 +292,11 @@ public class GridDhtPartitionDemander {
                     try {
                         requestPartitions(fut, assigns);
                     }
+                    catch (ClusterTopologyCheckedException e){
+                        log.warning("Failed to send initial demand request to node.", e);
+
+                        fut.cancel();
+                    }
                     catch (IgniteCheckedException e) {
                         log.error("Failed to send initial demand request to node.", e);
 


Mime
View raw message