# IGNITE-789 Review.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/96f3c037 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/96f3c037 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/96f3c037 Branch: refs/heads/ignite-286 Commit: 96f3c0373b4e28c55dae1c6ff6cde1712ad78b70 Parents: c33d096 Author: AKuznetsov <akuznet...@gridgain.com> Authored: Wed Apr 29 10:26:43 2015 +0700 Committer: AKuznetsov <akuznet...@gridgain.com> Committed: Wed Apr 29 10:26:43 2015 +0700 ---------------------------------------------------------------------- .../internal/visor/cache/VisorCacheStartTask.java | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/96f3c037/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java index 34f7b18..270c48a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStartTask.java @@ -35,7 +35,8 @@ import java.util.*; * Task that start cache or near cache with specified configuration. */ @GridInternal -public class VisorCacheStartTask extends VisorMultiNodeTask<IgniteBiTuple<String, String>, Void, Void> { +public class VisorCacheStartTask extends + VisorMultiNodeTask<IgniteBiTuple<String, String>, Map<UUID, IgniteException>, Void> { /** */ private static final long serialVersionUID = 0L; @@ -44,8 +45,15 @@ public class VisorCacheStartTask extends VisorMultiNodeTask<IgniteBiTuple<String return new VisorCacheStartJob(arg, debug); } - @Nullable @Override protected Void reduce0(List<ComputeJobResult> results) throws IgniteException { - return null; + /** {@inheritDoc} */ + @Nullable @Override protected Map<UUID, IgniteException> reduce0(List<ComputeJobResult> results) throws IgniteException { + Map<UUID, IgniteException> map = new HashMap<>(); + + for (ComputeJobResult res : results) + if (res.getException() != null) + map.put(res.getNode().id(), res.getException()); + + return map; } /**
