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

Question

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

我正专注于

未能反序列化对象[typename=org.apache.ignite.internal.processors.closure.gridclosureprocessor$C2]

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

原因：class org.apache.ignite.binary.binaryInvalidTypeException：未知对[platformid=0,typeid=-1409390795]

似乎丢失了封送缓存(marshaller/dir)。

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