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<UUID>> nodeToKeysMap = ignite.<UUID>affinity(getIgniteAffinityCacheName()).mapKeysToNodes(cacheKeys);
for (Map.Entry<ClusterNode, Collection<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/