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.java:62) >> Caused by: java.io.NotSerializableException: >> org.apache.ignite.internal.processors.cache.IgniteCacheProxy$6 >> at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream. >> java: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. >> java: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. >> java:1177) >> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream. >> java: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. >> java:1177) >> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream. >> java: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. >> java:1177) >> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream. >> java:347) >> at org.apache.ignite.internal.util.IgniteUtils.writeCollection( >> IgniteUtils.java:1646) >> at org.apache.ignite.internal.processors.continuous.GridContinu >> ousProcessor$DiscoveryData.writeExternal(GridContinuousPr >> ocessor.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. >> java:1177) >> at java.io.ObjectOutputStream.writeObject(ObjectOutputStream. >> java: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>
