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. > intellica.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$ > IgniteAllNodesPredicate@68e632be, hnd=CacheContinuousQueryHandlerV2 > [rmtFilterFactory=com.intellica.evam.engine.cache.DeploymentCacheListener$ > 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( > JdkMarshaller.java:84) > at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshalle > r.marshal(AbstractNodeNameAwareMarshaller.java:70) > at org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0( > JdkMarshaller.java:98) > at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshalle > r.marshal(AbstractNodeNameAwareMarshaller.java:58) > at org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi. > collectExchangeData(TcpDiscoverySpi.java:1685) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker. > processNodeAddedMessage(ServerImpl.java:3868) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker. > processJoinRequestMessage(ServerImpl.java:3516) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker. > processMessage(ServerImpl.java:2308) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker. > processMessage(ServerImpl.java:2136) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$ > MessageWorkerAdapter.body(ServerImpl.java:6124) > at org.apache.ignite.spi.discovery.tcp.ServerImpl$ > RingMessageWorker.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( > ObjectOutputStream.java:1547) > at java.io.ObjectOutputStream.writeSerialData( > ObjectOutputStream.java:1508) > at java.io.ObjectOutputStream.writeOrdinaryObject( > ObjectOutputStream.java:1431) > at java.io.ObjectOutputStream.writeObject0( > ObjectOutputStream.java:1177) > at java.io.ObjectOutputStream.defaultWriteFields( > ObjectOutputStream.java:1547) > at java.io.ObjectOutputStream.writeSerialData( > ObjectOutputStream.java:1508) > at java.io.ObjectOutputStream.writeOrdinaryObject( > ObjectOutputStream.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(CacheContinuousQueryHandlerV2. > java:157) > at java.io.ObjectOutputStream.writeExternalData( > ObjectOutputStream.java:1458) > at java.io.ObjectOutputStream.writeOrdinaryObject( > ObjectOutputStream.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. > GridContinuousProcessor$DiscoveryDataItem.writeExternal( > GridContinuousProcessor.java:1736) > at java.io.ObjectOutputStream.writeExternalData( > ObjectOutputStream.java:1458) > at java.io.ObjectOutputStream.writeOrdinaryObject( > ObjectOutputStream.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. > GridContinuousProcessor$DiscoveryData.writeExternal( > GridContinuousProcessor.java:1655) > at java.io.ObjectOutputStream.writeExternalData( > ObjectOutputStream.java:1458) > at java.io.ObjectOutputStream.writeOrdinaryObject( > ObjectOutputStream.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( > JdkMarshaller.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 Fax: +90 216 455 01 54 > www.evam.com.tr >
