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.AbstractNodeNameAwareMarshaller.marshal(AbstractNodeNameAwareMarshaller.java:70)
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkMarshaller.java:98)
at
org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.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
DeploymentCacheListener.java
Description: Binary data
