为什么cacheLoadOnlyStoreAdapter在加载过程中抛出NPE？

Question

我们从2.4.0切换到2.7.0。这可能是什么原因造成的？我不能排除我们的代码有问题，但我们不在堆栈中。

...忽略了14个常见帧，原因是：org.apache.ignite.ignite.internal.util.igniteutils.cast（igniteutils.java:7244)（org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.SessionEnd0(GridCacheStoreManagerAdapter.943)（org.apache.ignite.internal.processors.Cache.store.GridCacheStoreManagerAdapter.LoadCache(GridCacheStoreManagerAdapter.549)（org.apache.ignite.ignite.internal.processors.cac)he.distributed.dht.griddhtcacheadapter.localloadcache（griddhtcacheadapter.java:608)位于org.apache.ignite.internal.processors.cache.gridcacheproxyimpl.localloadcache（gridcacheproxyimpl.java:217)位于org.apache.ignite.internal.processors.cache.gridcacheadapter$loadcachejob.localexecute（gridcacheadapter.java:5520)

...省略了18个常见帧，原因是：java.lang.NullPoInterException：org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter$SessionData.Access$900（GridCacheStoreManagerAdapter.java:964)（org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.SessionEnd0(GridCacheStoreManagerAdapter.java:937)

public class XYZLoader
    extends CacheLoadOnlyStoreAdapter<XYZKey, byte[], XYZRecord>
    implements ComputeJob, Serializable {

    public XYZLoader(...) {

        reconfigureCacheLoadOnlyStoreAdapter(gridNodePhysicalThreadCount, externalParallelism);

    }

    private void reconfigureCacheLoadOnlyStoreAdapter(int gridNodePhysicalThreadCount, int externalParallelism) {
        int physicalThreadCount = ...

        this.setBatchSize(...);
        this.setBatchQueueSize(...);
        this.setThreadsCount(...);
    }

    int[] getLocalPartitions(Ignite ignite) {
        //...
        return ...;
    }

    @Override
    protected Iterator<XYZRecord> inputIterator(@Nullable Object... args) throws CacheLoaderException {
        int[] parts = getLocalPartitions(ignite);
        IgniteCluster cluster = ignite.cluster();
        ClusterNode localNode = cluster.localNode();
        int partitionCount = ignite.affinity(dataloadDescriptor.cacheName).partitions();

        Iterator<XYZRecord> reader = new XYZReader(parts, ...);

        iteratorFinishedFlag = false;

        return new Iterator<XYZRecord>() {
            // wrap inner iterator reader here..
        };
    }

    protected IgniteBiTuple<XYZKey, byte[]> parse(XYZRecord rec, @Nullable Object... args) {
        // parsing foo...
        return record;
    }

    @IgniteInstanceResource
    public void setIgnite(Ignite ignite) {
        this.ignite = ignite;
    }

    @Override // ComputeJob
    public void cancel() {
        throw new RuntimeException("Not implemented");
    }

    @Override // ComputeJob
    public Object execute() throws IgniteException {
        throw new RuntimeException("Not implemented");
    }

    @TaskSessionResource
    public void setTaskSession(ComputeTaskSession taskSes) {
        ComputeTaskSession ses = taskSes;
        logger.info(... ses);
    }
}

Answer 1

我打赌您忘记在CacheStore实现的某个地方调用super.method（）,从而导致底层数据结构的部分初始化。可能在loadCache（）或loadFromStore（）中。