sp-2 minor
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/efed98d2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/efed98d2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/efed98d2 Branch: refs/heads/ignite-gg-9828 Commit: efed98d2dbf7fc602dc2d28a892ec773642b82ad Parents: b1b8aca Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Wed Mar 11 15:36:33 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Wed Mar 11 15:36:33 2015 +0300 ---------------------------------------------------------------------- .../processors/task/GridTaskProcessor.java | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/efed98d2/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java index 67058f6..66ce261 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java @@ -152,8 +152,8 @@ public class GridTaskProcessor extends GridProcessorAdapter { task.cancel(); - Throwable ex = new ComputeTaskCancelledCheckedException("Task cancelled due to stopping of the grid: " + - task); + Throwable ex = + new ComputeTaskCancelledCheckedException("Task cancelled due to stopping of the grid: " + task); task.finishTask(null, ex, false); } @@ -437,7 +437,8 @@ public class GridTaskProcessor extends GridProcessorAdapter { "task (was task (re|un)deployed?) [taskName=" + taskName + ", dep=" + dep + ']'); if (!ComputeTask.class.isAssignableFrom(taskCls)) - throw new IgniteCheckedException("Failed to auto-deploy task (deployed class is not a task) [taskName=" + + throw new IgniteCheckedException("Failed to auto-deploy task (deployed class is not a task) " + + "[taskName=" + taskName + ", depCls=" + taskCls + ']'); } catch (IgniteCheckedException e) { @@ -453,8 +454,8 @@ public class GridTaskProcessor extends GridProcessorAdapter { dep = ctx.deploy().deploy(taskCls, U.detectClassLoader(taskCls)); if (dep == null) - throw new IgniteDeploymentCheckedException("Failed to auto-deploy task (was task (re|un)deployed?): " + - taskCls); + throw new IgniteDeploymentCheckedException("Failed to auto-deploy task " + + "(was task (re|un)deployed?): " + taskCls); taskName = taskName(dep, taskCls, map); } @@ -493,7 +494,8 @@ public class GridTaskProcessor extends GridProcessorAdapter { dep = ctx.deploy().deploy(cls, ldr); if (dep == null) - throw new IgniteDeploymentCheckedException("Failed to auto-deploy task (was task (re|un)deployed?): " + cls); + throw new IgniteDeploymentCheckedException("Failed to auto-deploy task " + + "(was task (re|un)deployed?): " + cls); taskName = taskName(dep, taskCls, map); } @@ -685,7 +687,8 @@ public class GridTaskProcessor extends GridProcessorAdapter { existingName = tasksMetaCache.putIfAbsent(key, taskName); if (existingName != null && !F.eq(existingName, taskName)) - throw new IgniteCheckedException("Task name hash collision for security-enabled node [taskName=" + taskName + + throw new IgniteCheckedException("Task name hash collision for security-enabled node " + + "[taskName=" + taskName + ", existing taskName=" + existingName + ']'); }
