[
https://issues.apache.org/jira/browse/IGNITE-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Micky Loo updated IGNITE-16638:
-------------------------------
Affects Version/s: 2.11
> Continuous query with Java thin client ignores page size and timeout interval
> -----------------------------------------------------------------------------
>
> Key: IGNITE-16638
> URL: https://issues.apache.org/jira/browse/IGNITE-16638
> Project: Ignite
> Issue Type: Bug
> Components: thin client
> Affects Versions: 2.11, 2.12
> Reporter: Micky Loo
> Priority: Major
>
> We are using the Java thin client and creating a continuous query with a page
> size and timeout interval.
> If I make 4 updates to the cache, the CacheEntryUpdatedListener is firing 4
> times immediately and there is no batching. The page size and timeout
> interval settings are being ignored.
> Sample code of how we are creating query
> {code:java}
> ClientCache<Integer, Set<Integer>> cache = client.cache("mycache");
> ContinuousQuery<Integer, Set<Integer>> query = new ContinuousQuery<Integer,
> Set<Integer>>()
> .setPageSize(100_000)
> .setTimeInterval(60_000)
> .setInitialQuery(new ScanQuery<>())
> .setLocalListener(new CacheEntryUpdatedListener<Integer, Set<Integer>>() {
> @Override
> public void onUpdated(Iterable<CacheEntryEvent<? extends Integer, ?
> extends Set<Integer>>> cacheEntryEvents)
> throws CacheEntryListenerException {
> System.out.println("Listener triggered.");
> }
> });
> cache.query(query, disconnectListener ->
> System.out.println("disconnected"));{code}
>
> This functionality behaves as expected with using thick client and the events
> are batched.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
