ignite-3426: Compute Engine: job ID is generated in a non unique way
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d2524eb5 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d2524eb5 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d2524eb5 Branch: refs/heads/ignite-3414 Commit: d2524eb545bfa1eca91c6cf0316297e29ff17b8d Parents: 5d9f899 Author: Denis Magda <[email protected]> Authored: Wed Jul 6 15:02:43 2016 +0300 Committer: Denis Magda <[email protected]> Committed: Wed Jul 6 15:02:43 2016 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/internal/processors/task/GridTaskWorker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d2524eb5/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 fc56893..8ce005a 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 @@ -561,7 +561,7 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { if (node == null) throw new IgniteCheckedException("Node can not be null [mappedJob=" + mappedJob + ", ses=" + ses + ']'); - IgniteUuid jobId = IgniteUuid.fromUuid(node.id()); + IgniteUuid jobId = IgniteUuid.fromUuid(ctx.localNodeId()); GridJobSiblingImpl sib = new GridJobSiblingImpl(ses.getId(), jobId, node.id(), ctx);
