Alper, Please check that fields in your DeploymentEvent.class also Serializable(or transient). Also, you can run ignite in debug mode and add breakpoint to the place where NotSerializableException throwed and check which object faced a problem with serialization.
Evgenii 2017-04-25 15:55 GMT+03:00 Alper Tekinalp <[email protected]>: > Hi Evgenii. > > If you mean "List<DeploymentEvent> events = e.getValue();" it is ArrayList. > > On Tue, Apr 25, 2017 at 12:21 PM, Evgenii Zhuravlev < > [email protected]> wrote: > >> Hi, >> >> Which List implementation do you use? Are you sure that it's implement >> Serializable? List not implement Serializable by itself. >> >> Evgenii >> >> 2017-04-24 19:18 GMT+03:00 Alper Tekinalp <[email protected]>: >> >>> Hi. >>> >>> I try to implement continuous query and it works fine on single node but >>> on mutiple nodes I get: >>> >>> 24/Apr/2017 19:14:04 ERROR 28326 [tcp-disco-msg-worker-#2%evam-grid%] >>> org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi(L:495) - Failed to >>> marshal discovery data [comp=0, data=DiscoveryData >>> [nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, items=[DiscoveryDataItem >>> [routineId=3f230dc7-e678-411d-bc2a-c0214717134b, prjPred= >>> o.a.i.configuration.CacheConfiguration$IgniteAllNodesPredicate@68e632be, >>> hnd=CacheContinuousQueryHandlerV2 [rmtFilterFactory=com.intellic >>> a.evam.engine.cache.DeploymentCacheListener$FilterFac@40871f40, >>> rmtFilterFactoryDep=null, types=0], bufSize=1, interval=0, >>> autoUnsubscribe=true], DiscoveryDataItem >>> [routineId=cc147f79-66b8-43ca-aef7-4fd8b7340ac2, >>> prjPred=o.a.i.i.util.lang.GridFunc$37@5a543d41, >>> hnd=CacheContinuousQueryHandler [cacheName=ignite-sys-cache, >>> rmtFilter=null, rmtFilterDep=null, internal=true, notifyExisting=true, >>> oldValRequired=true, sync=false, ignoreExpired=true, taskHash=0, >>> skipPrimaryCheck=true, locCache=false, keepBinary=false, >>> ackBuf=AcknowledgeBuffer [size=0, updateCntrs={}, topVers=[]], >>> cacheId=-2100569601, initTopVer=null, ignoreClsNotFound=false, >>> asyncCallback=false, nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, >>> routineId=cc147f79-66b8-43ca-aef7-4fd8b7340ac2], bufSize=1, interval=0, >>> autoUnsubscribe=true], DiscoveryDataItem >>> [routineId=ac8bac67-9c05-4114-92b2-926d5aeb941d, >>> prjPred=o.a.i.i.util.lang.GridFunc$37@535a2d71, >>> hnd=CacheContinuousQueryHandler [cacheName=ignite-marshaller-sys-cache, >>> rmtFilter=null, rmtFilterDep=null, internal=true, notifyExisting=true, >>> oldValRequired=true, sync=false, ignoreExpired=true, taskHash=0, >>> skipPrimaryCheck=true, locCache=false, keepBinary=false, >>> ackBuf=AcknowledgeBuffer [size=0, updateCntrs={}, topVers=[]], >>> cacheId=1325947219, initTopVer=null, ignoreClsNotFound=false, >>> asyncCallback=false, nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, >>> routineId=ac8bac67-9c05-4114-92b2-926d5aeb941d], bufSize=1, interval=0, >>> autoUnsubscribe=true]]]] >>> class org.apache.ignite.IgniteCheckedException: Failed to serialize >>> object: DiscoveryData [nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, >>> items=[DiscoveryDataItem [routineId=3f230dc7-e678-411d-bc2a-c0214717134b, >>> prjPred=org.apache.ignite.configuration.CacheConfiguration$I >>> gniteAllNodesPredicate@68e632be, hnd=CacheContinuousQueryHandlerV2 >>> [rmtFilterFactory=com.intellica.evam.engine.cache.Deployment >>> CacheListener$FilterFac@40871f40, rmtFilterFactoryDep=null, types=0], >>> bufSize=1, interval=0, autoUnsubscribe=true], DiscoveryDataItem >>> [routineId=cc147f79-66b8-43ca-aef7-4fd8b7340ac2, >>> prjPred=org.apache.ignite.internal.util.lang.GridFunc$37@5a543d41, >>> hnd=CacheContinuousQueryHandler [cacheName=ignite-sys-cache, >>> rmtFilter=null, rmtFilterDep=null, internal=true, notifyExisting=true, >>> oldValRequired=true, sync=false, ignoreExpired=true, taskHash=0, >>> skipPrimaryCheck=true, locCache=false, keepBinary=false, >>> ackBuf=AcknowledgeBuffer [size=0, updateCntrs={}, topVers=[]], >>> cacheId=-2100569601, initTopVer=null, ignoreClsNotFound=false, >>> asyncCallback=false, nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, >>> routineId=cc147f79-66b8-43ca-aef7-4fd8b7340ac2], bufSize=1, interval=0, >>> autoUnsubscribe=true], DiscoveryDataItem >>> [routineId=ac8bac67-9c05-4114-92b2-926d5aeb941d, >>> prjPred=org.apache.ignite.internal.util.lang.GridFunc$37@535a2d71, >>> hnd=CacheContinuousQueryHandler [cacheName=ignite-marshaller-sys-cache, >>> rmtFilter=null, rmtFilterDep=null, internal=true, notifyExisting=true, >>> oldValRequired=true, sync=false, ignoreExpired=true, taskHash=0, >>> skipPrimaryCheck=true, locCache=false, keepBinary=false, >>> ackBuf=AcknowledgeBuffer [size=0, updateCntrs={}, topVers=[]], >>> cacheId=1325947219, initTopVer=null, ignoreClsNotFound=false, >>> asyncCallback=false, nodeId=b1104b9d-dffa-48e0-941d-b7ec0e4d6bbb, >>> routineId=ac8bac67-9c05-4114-92b2-926d5aeb941d], bufSize=1, interval=0, >>> autoUnsubscribe=true]]] >>> at org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkM >>> arshaller.java:84) >>> at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller >>> .marshal(AbstractNodeNameAwareMarshaller.java:70) >>> at org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkM >>> arshaller.java:98) >>> at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller >>> .marshal(AbstractNodeNameAwareMarshaller.java:58) >>> at org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.collectE >>> xchangeData(TcpDiscoverySpi.java:1685) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWo >>> rker.processNodeAddedMessage(ServerImpl.java:3868) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWo >>> rker.processJoinRequestMessage(ServerImpl.java:3516) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWo >>> rker.processMessage(ServerImpl.java:2308) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWo >>> rker.processMessage(ServerImpl.java:2136) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$MessageWorker >>> Adapter.body(ServerImpl.java:6124) >>> at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWo >>> rker.body(ServerImpl.java:2223) >>> at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.ja >>> va:62) >>> Caused by: java.io.NotSerializableException: >>> org.apache.ignite.internal.processors.cache.IgniteCacheProxy$6 >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1183) >>> at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputSt >>> ream.java:1547) >>> at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStrea >>> m.java:1508) >>> at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputS >>> tream.java:1431) >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1177) >>> at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputSt >>> ream.java:1547) >>> at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStrea >>> m.java:1508) >>> at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputS >>> tream.java:1431) >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1177) >>> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.ja >>> va:347) >>> at org.apache.ignite.internal.processors.cache.query.continuous >>> .CacheContinuousQueryHandlerV2.writeExternal(CacheContinuous >>> QueryHandlerV2.java:157) >>> at java.io.ObjectOutputStream.writeExternalData(ObjectOutputStr >>> eam.java:1458) >>> at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputS >>> tream.java:1429) >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1177) >>> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.ja >>> va:347) >>> at org.apache.ignite.internal.processors.continuous.GridContinu >>> ousProcessor$DiscoveryDataItem.writeExternal(GridContinuousP >>> rocessor.java:1736) >>> at java.io.ObjectOutputStream.writeExternalData(ObjectOutputStr >>> eam.java:1458) >>> at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputS >>> tream.java:1429) >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1177) >>> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.ja >>> va:347) >>> at org.apache.ignite.internal.util.IgniteUtils.writeCollection( >>> IgniteUtils.java:1646) >>> at org.apache.ignite.internal.processors.continuous.GridContinu >>> ousProcessor$DiscoveryData.writeExternal(GridContinuousProce >>> ssor.java:1655) >>> at java.io.ObjectOutputStream.writeExternalData(ObjectOutputStr >>> eam.java:1458) >>> at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputS >>> tream.java:1429) >>> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.j >>> ava:1177) >>> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.ja >>> va:347) >>> at org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkM >>> arshaller.java:79) >>> ... 11 more >>> >>> My implementation class is attached. DeploymentEvent class implements >>> Serializable. >>> >>> Can someone guide me what is wrong? >>> >>> -- >>> Alper Tekinalp >>> >>> Software Developer >>> Evam Streaming Analytics >>> >>> Atatürk Mah. Turgut Özal Bulv. >>> Gardenya 5 Plaza K:6 Ataşehir >>> 34758 İSTANBUL >>> >>> Tel: +90 216 455 01 53 <+90%20216%20455%2001%2053> Fax: +90 216 455 01 >>> 54 <+90%20216%20455%2001%2054> >>> www.evam.com.tr >>> >> >> > > > -- > Alper Tekinalp > > Software Developer > Evam Streaming Analytics > > Atatürk Mah. Turgut Özal Bulv. > Gardenya 5 Plaza K:6 Ataşehir > 34758 İSTANBUL > > Tel: +90 216 455 01 53 Fax: +90 216 455 01 54 > www.evam.com.tr > <http://www.evam.com> >
