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/e7f9b385 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/e7f9b385 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/e7f9b385 Branch: refs/heads/ignite-286 Commit: e7f9b385e82b9b88f82bbc3fe3d997bc737ec7c3 Parents: a40ae51 Author: AKuznetsov <akuznet...@gridgain.com> Authored: Tue Apr 28 17:24:18 2015 +0700 Committer: AKuznetsov <akuznet...@gridgain.com> Committed: Tue Apr 28 17:24:18 2015 +0700 ---------------------------------------------------------------------- .../ignite/internal/visor/cache/VisorCacheStartTask.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/e7f9b385/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 bb0b781..34f7b18 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 @@ -18,6 +18,7 @@ package org.apache.ignite.internal.visor.cache; import org.apache.ignite.*; +import org.apache.ignite.compute.*; import org.apache.ignite.configuration.*; import org.apache.ignite.internal.processors.task.*; import org.apache.ignite.internal.util.typedef.*; @@ -25,14 +26,16 @@ import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.internal.visor.*; import org.apache.ignite.internal.visor.util.*; import org.apache.ignite.lang.*; +import org.jetbrains.annotations.*; import java.io.*; +import java.util.*; /** * Task that start cache or near cache with specified configuration. */ @GridInternal -public class VisorCacheStartTask extends VisorOneNodeTask<IgniteBiTuple<String, String>, Void> { +public class VisorCacheStartTask extends VisorMultiNodeTask<IgniteBiTuple<String, String>, Void, Void> { /** */ private static final long serialVersionUID = 0L; @@ -41,6 +44,10 @@ public class VisorCacheStartTask extends VisorOneNodeTask<IgniteBiTuple<String, return new VisorCacheStartJob(arg, debug); } + @Nullable @Override protected Void reduce0(List<ComputeJobResult> results) throws IgniteException { + return null; + } + /** * Job that start cache or near cache with specified configuration. */
