Re: ComputeTask is including Nodes for ComputeJobs prematurely

[Chris Berry]

Hmmm, the raw code does not appear to be visible.
Reposting....

    public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode>
subgrid, @Nullable TRequest request) throws IgniteException {
            Map<ComputeJob, ClusterNode> jobMap = new HashMap<>();
            List<UUID> cacheKeys = getIgniteAffinityCacheKeys(request);
            Map<ClusterNode, Collection&lt;UUID>> nodeToKeysMap =
ignite.<UUID>affinity(getIgniteAffinityCacheName()).mapKeysToNodes(cacheKeys);

            for (Map.Entry<ClusterNode, Collection&lt;UUID>> mapping :
nodeToKeysMap.entrySet()) {
                ClusterNode node = mapping.getKey();
                Collection<UUID> mappedKeys = mapping.getValue();
                final List<UUID> uuidList = (mappedKeys instanceof List ?
(List<UUID>) mappedKeys : new ArrayList<>(mappedKeys));
                if (node != null) {
                    TRequest reducedRequest =
requestWithPerNodeUUIDs(request, uuidList);
                    AbstractComputeJob job = createJob(reducedRequest,
context);
                    jobMap.put(job, node);
                }
            }
           return jobMap;
    }

Thanks,
-- Chris



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/