ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [27/50] [abbrv] incubator-ignite git commit: sp-2 minor
Date Wed, 11 Mar 2015 19:49:55 GMT
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-406
Commit: efed98d2dbf7fc602dc2d28a892ec773642b82ad
Parents: b1b8aca
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Wed Mar 11 15:36:33 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@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 + ']');
     }
 


Mime
View raw message