[ https://issues.apache.org/jira/browse/IGNITE-8528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480911#comment-16480911 ]
Andrey Gura commented on IGNITE-8528: ------------------------------------- Merged to master and ignite-2.5 branches. > Peer deployment does not work for continuous query transformers > --------------------------------------------------------------- > > Key: IGNITE-8528 > URL: https://issues.apache.org/jira/browse/IGNITE-8528 > Project: Ignite > Issue Type: Improvement > Affects Versions: 2.5 > Reporter: Alexey Goncharuk > Assignee: Nikolay Izhikov > Priority: Major > Fix For: 2.5 > > > Build local Ignite distribution using > {code} > mvn clean install -Pall-java,all-scala,licenses -DskipTests > mvn initialize -Prelease > {code} > Start one node in console and run continuous query with transformer example > in IDE. I am getting the following exception: > {code} > [15:30:43] To start Console Management & Monitoring run > ignitevisorcmd.{sh|bat} > [15:30:43] > [15:30:43] Ignite node started OK (id=f1356a5b) > [15:30:43] Topology snapshot [ver=1, servers=1, clients=0, CPUs=16, > offheap=19.0GB, heap=2.0GB] > [15:30:43] ^-- Node [id=F1356A5B-4CDB-4480-A64F-35BF2C96DBB5, > clusterState=ACTIVE] > [15:30:43] Data Regions Configured: > [15:30:43] ^-- default [initSize=256.0 MiB, maxSize=18.9 GiB, > persistenceEnabled=false] > [15:30:52] Topology snapshot [ver=2, servers=2, clients=0, CPUs=16, > offheap=38.0GB, heap=3.0GB] > [15:30:52] ^-- Node [id=F1356A5B-4CDB-4480-A64F-35BF2C96DBB5, > clusterState=ACTIVE] > [15:30:52] Data Regions Configured: > [15:30:52] ^-- default [initSize=256.0 MiB, maxSize=18.9 GiB, > persistenceEnabled=false] > [15:30:53,065][SEVERE][tcp-disco-msg-worker-#2][BinaryContext] Failed to > deserialize object [typeName=java.lang.invoke.SerializedLambda] > class org.apache.ignite.binary.BinaryObjectException: Failed to read field > [name=capturingClass] > at > org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:187) > at > org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:870) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1762) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.readField(BinaryReaderExImpl.java:1982) > at > org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.read0(BinaryFieldAccessor.java:698) > at > org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:183) > at > org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:870) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1762) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714) > at > org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java:310) > at > org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal0(BinaryMarshaller.java:99) > at > org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.unmarshal(AbstractNodeNameAwareMarshaller.java:82) > at > org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9962) > at > org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9991) > at > org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryDeployableObject.unmarshal(CacheContinuousQueryDeployableObject.java:94) > at > org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV3.p2pUnmarshal(CacheContinuousQueryHandlerV3.java:155) > at > org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.processStartRequest(GridContinuousProcessor.java:1327) > at > org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.access$400(GridContinuousProcessor.java:108) > at > org.apache.ignite.internal.processors.continuous.GridContinuousProcessor$2.onCustomEvent(GridContinuousProcessor.java:200) > at > org.apache.ignite.internal.processors.continuous.GridContinuousProcessor$2.onCustomEvent(GridContinuousProcessor.java:191) > at > org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$4.onDiscovery0(GridDiscoveryManager.java:707) > at > org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$4.onDiscovery(GridDiscoveryManager.java:589) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.notifyDiscoveryListener(ServerImpl.java:5479) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processCustomMessage(ServerImpl.java:5305) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2765) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2536) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$MessageWorkerAdapter.body(ServerImpl.java:6775) > at > org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.body(ServerImpl.java:2621) > at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62) > Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: > org.apache.ignite.examples.datagrid.CacheContinuousQueryWithTransformerExample > at > org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:697) > at > org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1631) > at > org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1568) > at > org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1545) > at > org.apache.ignite.internal.binary.BinaryReaderExImpl.readClass(BinaryReaderExImpl.java:380) > at > org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.readFixedType(BinaryFieldAccessor.java:902) > at > org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.read0(BinaryFieldAccessor.java:698) > at > org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:183) > ... 29 more > Caused by: java.lang.ClassNotFoundException: > org.apache.ignite.examples.datagrid.CacheContinuousQueryWithTransformerExample > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:348) > at > org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8608) > at > org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:349) > at > org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:688) > ... 36 more > {code} > Note that CacheContinuousQueryExample works fine in this case. -- This message was sent by Atlassian JIRA (v7.6.3#76005)