IGNITE-5694 - Added retries for getCollection in DataStructuresProcessor - Fixes #2240.
Signed-off-by: Alexey Goncharuk <alexey.goncha...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/17694c16 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/17694c16 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/17694c16 Branch: refs/heads/master Commit: 17694c16d449dea4d4e39a271dd39e838c581858 Parents: 36716fb Author: Ilya Lantukh <ilant...@gridgain.com> Authored: Mon Jul 10 11:59:19 2017 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Mon Jul 10 11:59:19 2017 +0300 ---------------------------------------------------------------------- .../processors/datastructures/DataStructuresProcessor.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/17694c16/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java index 5564b79..33a2fd2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java @@ -1031,7 +1031,11 @@ public final class DataStructuresProcessor extends GridProcessorAdapter implemen } } - return c.applyx(cache.context()); + return retryTopologySafe(new IgniteOutClosureX<T>() { + @Override public T applyx() throws IgniteCheckedException { + return c.applyx(cache.context()); + } + }); } /**
