removed unnecessary iteration

Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b1b8aca1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b1b8aca1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b1b8aca1

Branch: refs/heads/ignite-gg-9828
Commit: b1b8aca1b6e39a3005938ea2ebbaed5aa81c8ed5
Parents: b3bff7e
Author: Yakov Zhdanov <yzhda...@gridgain.com>
Authored: Wed Mar 11 15:26:16 2015 +0300
Committer: Yakov Zhdanov <yzhda...@gridgain.com>
Committed: Wed Mar 11 15:26:16 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/task/GridTaskProcessor.java   | 14 --------------
 1 file changed, 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b1b8aca1/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 b8aba9f..67058f6 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
@@ -565,20 +565,6 @@ public class GridTaskProcessor extends 
GridProcessorAdapter {
                     map,
                     subjId);
 
-                if (task != null) {
-                    // Check if someone reuses the same task instance by 
walking
-                    // through the "tasks" map
-                    for (GridTaskWorker worker : tasks.values()) {
-                        ComputeTask workerTask = worker.getTask();
-
-                        // Check that the same instance of task is being used 
by comparing references.
-                        if (workerTask != null && task == workerTask)
-                            U.warn(log, "Most likely the same task instance is 
being executed. " +
-                                "Please avoid executing the same task 
instances in parallel because " +
-                                "they may have concurrent resources access and 
conflict each other: " + task);
-                    }
-                }
-
                 GridTaskWorker<?, ?> taskWorker0 = tasks.putIfAbsent(sesId, 
taskWorker);
 
                 assert taskWorker0 == null : "Session ID is not unique: " + 
sesId;

Reply via email to