ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [7/7] ignite git commit: 1093
Date Thu, 22 Oct 2015 09:48:39 GMT
1093


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

Branch: refs/heads/ignite-1093-2
Commit: 1e041fbade1d599c57da1e9815b942c1b4c3e2d7
Parents: ea9f671
Author: Anton Vinogradov <av@apache.org>
Authored: Thu Oct 22 12:48:18 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Thu Oct 22 12:48:18 2015 +0300

----------------------------------------------------------------------
 .../apache/ignite/internal/processors/task/GridTaskWorker.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1e041fba/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
index 26a41de..9315d7c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java
@@ -696,7 +696,9 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject
{
                         if (log.isDebugEnabled())
                             U.warn(log, "Received response for unknown child job (was job
presumed failed?): " + res);
 
-                        return;
+                        selfOccupied = true;
+
+                        continue;
                     }
 
                     // Only process 1st response and ignore following ones. This scenario


Mime
View raw message