为什么 ignite 无法反序列化 GridClosureProcessor 对象？

Question

我知道其他人已经发布了类似的堆栈。我的问题是“看起来 Ignite 正试图反序列化一个 GridClosureProcessor（或它的闭包？）。如果是这样，为什么要这样做？我试图从根本上导致这个问题，但我的代码都没有在堆栈中，除了MyCallable 在顶部提到（实际上不在堆栈中）。

除非它们是内部的，否则此代码路径中不会发生缓存放置。我之所以提到这一点，是因为另一篇文章的评论说“未知对”可能是由错误类型的缓存放置引起的。

我专注于

无法反序列化对象 [typeName=org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2]

剩下的就到这里了。

[2019-04-08 22:20:23,724][ERROR][pub-#63][GridJobWorker] 失败 初始化作业 [jobId=800890ff961-7ff6a786-9d4d-43d8-91a0-70225c5e3a4a, ses=GridJobSessionImpl [ses=GridTaskSessionImpl [taskName=com.obfucorp.aa.project.core.jobs.MyCallable, dep=GridDeployment [ts=1554761996013，depMode=SHARED， clsLdr=sun.misc.Launcher$AppClassLoader@764c12b6, clsLdrId=730290ff961-8d93b961-09f2-48c3-bd2f-49db31aae61e, userVer=0, 位置=真， sampleClsName=o.a.i.i.processors.cache.GridCacheProcessor$RemovedItemsCleanupTask$1, pendingUndeploy=false，未部署=false，usage=1]， taskClsName=com.obfucorp.aa.project.core.jobs.MyCallable, sesId=700890ff961-7ff6a786-9d4d-43d8-91a0-70225c5e3a4a, 开始时间=1554762023663，结束时间=9223372036854775807， taskNodeId=7ff6a786-9d4d-43d8-91a0-70225c5e3a4a, clsLdr=sun.misc.Launcher$AppClassLoader@764c12b6，关闭=假， cpSpi=null，failSpi=null，loadSpi=null，usage=1，fullSup=false， 内部=假，topPred=null， subjId=7ff6a786-9d4d-43d8-91a0-70225c5e3a4a, mapFut=IgniteFuture [orig=GridFutureAdapter [ignoreInterrupts=false, state=INIT, res=null, 哈希=314803578]]，execName=null]， jobId=800890ff961-7ff6a786-9d4d-43d8-91a0-70225c5e3a4a]] 类 org.apache.ignite.IgniteCheckedException：无法反序列化对象 [typeName=org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2] 在 org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9908) 在 org.apache.ignite.internal.processors.job.GridJobWorker.initialize(GridJobWorker.java:438) 在 org.apache.ignite.internal.processors.job.GridJobProcessor.processJobExecuteRequest(GridJobProcessor.java:1117) 在 org.apache.ignite.internal.processors.job.GridJobProcessor$JobExecutionListener.onMessage(GridJobProcessor.java:1921) 在 org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1555) 在 org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:1183) 在 org.apache.ignite.internal.managers.communication.GridIoManager.access$4200(GridIoManager.java:126) 在 org.apache.ignite.internal.managers.communication.GridIoManager$9.run(GridIoManager.java:1090) 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 在 java.lang.Thread.run(Thread.java:748) 引起：类 org.apache.ignite.binary.BinaryObjectException：反序列化失败 目的 [typeName=org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2] 在 org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:875) 在 org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1762) 在 org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714) 在 org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java:310) 在 org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal0(BinaryMarshaller.java:99) 在 org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.unmarshal（AbstractNodeNameAwareMarshaller.java:82） 在 org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9902) ... 10 更多原因：类 org.apache.ignite.binary.BinaryInvalidTypeException：未知对 [platformId=0, typeId=-1409390795] 在 org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:696) 在 org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1755) 在 org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714) 在 org.apache.ignite.internal.binary.BinaryUtils.doReadObject(BinaryUtils.java:1799) 在 org.apache.ignite.internal.binary.BinaryReaderExImpl.readObject(BinaryReaderExImpl.java:1329) 在 org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2.readBinary(GridClosureProcessor.java:1872) 在 org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:834) ... 16 更多原因：java.lang.ClassNotFoundException：未知对 [platformId=0, typeId=-1409390795] 在 org.apache.ignite.internal.MarshallerContextImpl.getClassName(MarshallerContextImpl.java:385) 在 org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:335) 在 org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:687) ... 22 更多

更新 - 想指出这是一个全新的部署。周围没有旧文件或保留任何东西。所有类要么是从偶数中提取的，要么是新编译的。太棒了。

Pavel，这是（Scala）代码（已编辑）

object MyCallable {
    type FooList = Array[Foo]
}

class MyCallable(cacheName: String) extends IgniteCallable[FooList] with Serializable with LazyLogging {
    @IgniteInstanceResource
    private var ignite: Ignite = _

    override def call(): FooList = {
        logger.debug("callable called.");
        val fooCache = ignite.getOrCreateCache[String, Foo](cacheName)
        val qry = new ScanQuery[String, Foo]()
        qry.setLocal(true)
        val cursor = fooCache.query(qry)
        val ret = cursor.iterator().asScala.map(e => e.getValue).toArray
        logger.info("load status array: {}", ret.mkString)
        return ret
    }

    @IgniteInstanceResource
    def setIgnite(ignite: Ignite): Unit = {
        this.ignite = ignite
    }
}

Answer 1

Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: Unknown pair [platformId=0, typeId=-1409390795]

您好像丢失了编组器缓存 (marshaller/ dir)。

您可以执行一次ignite.marshaller().marshal(new WhateverTypeIsCausingThis()); 以消除此错误。