-
Bug
-
Resolution: Done
-
Major
-
5.1.1.FINAL
-
None
1) using DistributedExecutorService::submit with non <distributable-cache> results in NPE
protected <K> Map<Address, List<K>> mapKeysToNodes(K... input) {
DistributionManager dm = cache.getDistributionManager();
Map<Address, List<K>> addressToKey = new HashMap<Address, List<K>>(input.length * 2);
for (K key : input) {
Address ownerOfKey = dm.getPrimaryLocation(key); // <------- dm is null