You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by Alper Tekinalp <al...@evam.com> on 2017/04/24 16:18:24 UTC
Marshalling exception on continuous query
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
Re: Marshalling exception on continuous query
Posted by Evgenii Zhuravlev <e....@gmail.com>.
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 <al...@evam.com>:
> Hi Evgenii.
>
> If you mean "List<DeploymentEvent> events = e.getValue();" it is ArrayList.
>
> On Tue, Apr 25, 2017 at 12:21 PM, Evgenii Zhuravlev <
> e.zhuravlev.wk@gmail.com> 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 <al...@evam.com>:
>>
>>> 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>
>
Re: Marshalling exception on continuous query
Posted by Alper Tekinalp <al...@evam.com>.
Hi Evgenii.
If you mean "List<DeploymentEvent> events = e.getValue();" it is ArrayList.
On Tue, Apr 25, 2017 at 12:21 PM, Evgenii Zhuravlev <
e.zhuravlev.wk@gmail.com> 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 <al...@evam.com>:
>
>> 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>
Re: Marshalling exception on continuous query
Posted by Evgenii Zhuravlev <e....@gmail.com>.
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 <al...@evam.com>:
> 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
>