ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Lin" ...@linlyu.com>
Subject CacheContinuousQuery did not work after the second server node joinned into the topology.
Date Thu, 29 Sep 2016 12:42:47 GMT
Hi all, I have a question on CacheContinuousQuery, after the second server node joined into
the topology, the continuous query in the client is not worked.


My ignite version is 1.6.0, here is my tests:
1. start the first server node by running ServerNode.java
2. start the CQClient.java to create a continuous query client, and waiting for the CacheContinuousQueryEvent(s)
with a remote filter.
3. start a data client by running DataPuttingClient.java, it will putting some data into the
cache. And, at the same time, the CQClient can receive the filtered events.
see the outputs in [1].
4. you can run the step 3 any times, and you can get the similar results like [1].
5. but if you start a second server node by running ServerNode.java, and put data by running
DataPuttingClient.java, it is weired that the server(s) processed the filters, but the client
didn't receive any CacheContinuousQueryEvent even if the filter result is true, so the CQClient
did not output anything like [1]. 


You can reproduce it with the codes and settings in src-config.zip (see the attachement).


[1] example outputs


server1 outputs result after first time running of DataPuttingClient.
[20:21:01] Topology snapshot [ver=3, servers=1, clients=2, CPUs=8, heap=11.0GB]
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=CREATED, key=5, newVal=0,
oldVal=null], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=1,
oldVal=0], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=2,
oldVal=1], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=3,
oldVal=2], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=4,
oldVal=3], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=5,
oldVal=4], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=6,
oldVal=5], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=7,
oldVal=6], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=8,
oldVal=7], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=9,
oldVal=8], with ret true
[20:21:01] Topology snapshot [ver=4, servers=1, clients=1, CPUs=8, heap=7.1GB]


server1 outputs result after the second time running of DataPuttingClient.
[20:21:24] Topology snapshot [ver=5, servers=1, clients=2, CPUs=8, heap=11.0GB]
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=0,
oldVal=9], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=1,
oldVal=0], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=2,
oldVal=1], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=3,
oldVal=2], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=4,
oldVal=3], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=5,
oldVal=4], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=6,
oldVal=5], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=7,
oldVal=6], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=8,
oldVal=7], with ret true
CacheEntryEventRemoteFilter.evaluate CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=9,
oldVal=8], with ret true


CQClient's outputs after first time run of DataPuttingClient
sys-#2%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=CREATED, key=5, newVal=0,
oldVal=null]
sys-#2%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=1,
oldVal=0]
sys-#13%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=2,
oldVal=1]
sys-#10%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=3,
oldVal=2]
sys-#11%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=4,
oldVal=3]
sys-#14%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=5,
oldVal=4]
sys-#3%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=6,
oldVal=5]
sys-#7%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=7,
oldVal=6]
sys-#16%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=8,
oldVal=7]
sys-#4%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=9,
oldVal=8]


CQClient's outputs after the second time running of DataPuttingClient
sys-#5%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=0,
oldVal=9]
sys-#6%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=1,
oldVal=0]
sys-#9%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=2,
oldVal=1]
sys-#8%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=3,
oldVal=2]
sys-#2%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=4,
oldVal=3]
sys-#13%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=5,
oldVal=4]
sys-#10%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=6,
oldVal=5]
sys-#11%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=7,
oldVal=6]
sys-#14%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=8,
oldVal=7]
sys-#3%null% receive CacheEntryEvent CacheContinuousQueryEvent [evtType=UPDATED, key=5, newVal=9,
oldVal=8]
Mime
View raw message