I meant that `MapReduceCacheLoaderTask` should also run the combiner and insert the entries in the intermediary cache, just like the anonymous Callable passed to `dc.executeTask()`. It's not at all clear to me how the intermediary keys/values that are generated from the cache loader entries are inserted in the intermediary cache. Also, couldn't you pass the same Callable to both `dc.executeTask()` and `persistenceManager.processOnAllStores()`?