ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yzhda...@apache.org
Subject incubator-ignite git commit: removed unnecessary iteration
Date Wed, 11 Mar 2015 12:26:25 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/sprint-2 b3bff7efb -> b1b8aca1b


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/sprint-2
Commit: b1b8aca1b6e39a3005938ea2ebbaed5aa81c8ed5
Parents: b3bff7e
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Wed Mar 11 15:26:16 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@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;


Mime
View raw message