Зажечь проблему сериализации в QueryCursor - PullRequest
Новая
       18

Зажечь проблему сериализации в QueryCursor

0 голосов
/ 02 апреля 2019

Я новичок в том, чтобы зажигать и пытаться «заполнить» кеш из EntryProcessor, но не могу проследить результаты ScanQuery в приложении.enabled: 

Cache A : IgniteCache<Long, A>
Cache B : IgniteCache<UUID, ScheduledTask>


interface ScheduledTask extends Serializable {
     Instant getExecuteAt()
}

one of classes that are stored in cache B:

class ExpirationTask implements ScheduledTask

Приложение Spring boot (написано на Kotlin) асинхронно вызывает процессор ввода для кэша A. Процессор заполняет данные в обоих кэшах (A и B).Затем приложение запрашивает кэш B: 

 val dueQuery = ScanQuery<UUID, ScheduledTask> { _, task -> task.executeAt <= now }

       bCache.query(dueQuery, { it.key }).use { taskKeys ->
            for (taskKey in taskKeys) {
   ………………………
          }
}

Но курсор запроса выдает ClassCastException: 

Caused by: java.lang.ClassCastException: ExpirationTask cannot be cast to ScheduledTask
    at ….Scheduler$poll$dueQuery$1.apply(Scheduler:61)
    at org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$ScanQueryIterator.advance(GridCacheQueryManager.java:3089)
    at org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager$ScanQueryIterator.onHasNext(GridCacheQueryManager.java:2982)
    at org.apache.ignite.internal.util.GridCloseableIteratorAdapter.hasNextX(GridCloseableIteratorAdapter.java:53)
    at org.apache.ignite.internal.util.lang.GridIteratorAdapter.hasNext(GridIteratorAdapter.java:45)
    at org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager.runQuery(GridCacheQueryManager.java:1164)
    at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager.processQueryRequest(GridCacheDistributedQueryManager.java:230)
    at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager$2.apply(GridCacheDistributedQueryManager.java:108)
    at org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager$2.apply(GridCacheDistributedQueryManager.java:106)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager.processMessage(GridCacheIoManager.java:1054)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:579)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:378)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:304)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$100(GridCacheIoManager.java:99)
    at org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:293)
    at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1556)
    at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:1184)
    at org.apache.ignite.internal.managers.communication.GridIoManager.access$4200(GridIoManager.java:125)
    at org.apache.ignite.internal.managers.communication.GridIoManager$9.run(GridIoManager.java:1091)
    ... 3 common frames omitted

OptimizedMarshaller маршалирует оба класса A и B из-за пользовательской сериализации, такой как: 

data class B(val dueTime: Instant, val id: Long) : ScheduledTask {

 override fun getExecuteAt(): Instant {
        return dueTime
    }
    private fun writeObject(stream: ObjectOutputStream) {
        // Only used to indicate custom serialization for Ignite. Real work done by writeReplace()
    }

    private fun readObject(stream: ObjectInputStream) {
        // Only used to indicate custom serialization for Ignite. Real work done by writeReplace()
    }

    private fun writeReplace(): Any = Serializer(this)

    class Serializer @JvmOverloads constructor(var source: B? = null) : Externalizable {
        override fun readExternal(stream: ObjectInput) {
            val dueTime = stream.readObject() as Instant
            val id = stream.readLong()
           source = B(dueTime, id)
        }

        override fun writeExternal(stream: ObjectOutput) {
            stream.writeObject(source!!.dueTime)
            stream.writeLong(source!!.id)
       }

        private fun readResolve(): Any = source!!

        companion object {
            private const val serialVersionUID: Long = 1
        }
    }

    companion object {
        private const val serialVersionUID: Long = 42
    }
}

Итак, я ищу способ выполнять полиморфные запросы к значениям кэша.

Спасибо

1 Ответ

0 голосов
/ 03 апреля 2019
  • Ignite не будет использовать типы ключей / значений для кеш-загрузки, поэтому вам не стоит об этом беспокоиться.
  • Возможно ли, что B загружен разными загрузчиками классов? Вы можете отладить это, проверив getClass().getClassLoader() из B.
  • Может быть, Котлин в какой-то момент ожидает завернутый тип B?
...