You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/05/10 14:40:47 UTC
[06/13] ignite git commit: IGNITE-5119 Append extra message to
exception when unable to determine affinity
IGNITE-5119 Append extra message to exception when unable to determine affinity
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5dc98962
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5dc98962
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5dc98962
Branch: refs/heads/ignite-5009
Commit: 5dc989624da19f400f69f2ea61cfa1d26659739a
Parents: 8c3ac14
Author: William Do <bl...@gmail.com>
Authored: Mon May 8 11:17:42 2017 -0700
Committer: Denis Magda <dm...@gridgain.com>
Committed: Mon May 8 11:17:42 2017 -0700
----------------------------------------------------------------------
.../internal/processors/affinity/GridAffinityProcessor.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5dc98962/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java
index e1b9f64..e57cf54 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessor.java
@@ -186,7 +186,8 @@ public class GridAffinityProcessor extends GridProcessorAdapter {
aff = affinityCache(cacheName, ctx.discovery().topologyVersionEx());
if (aff == null)
- throw new IgniteCheckedException("Failed to get cache affinity.");
+ throw new IgniteCheckedException("Failed to get cache affinity (cache was not started " +
+ "yet or cache was already stopped): " + cacheName);
}
return aff.affFunc.partition(aff.affinityKey(key));