Micky Loo created IGNITE-16638:
----------------------------------
Summary: 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.12
Reporter: Micky Loo
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)
