ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vladislav Pyatkov <vldpyat...@gmail.com>
Subject Re: CacheContinuousQuery did not work after the second server node joinned into the topology.
Date Thu, 29 Sep 2016 15:07:04 GMT
Hi Lin,

I tried, to reproduce the issue, but could not to do it.
I checked your example on 6.0.0 and 7.0.0 version of Ignite and it works
correct.

Please, clarify is attached example working as you say?



On Thu, Sep 29, 2016 at 3:42 PM, Lin <me@linlyu.com> wrote:

> 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]
>
>


-- 
Vladislav Pyatkov

Mime
View raw message