[IGNITE-16638] Continuous query with Java thin client ignores page size and timeout interval

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.11, 2.12
• Component/s: thin client
• Ignite Flags: Docs Required, Release Notes Required
• Assignee: Igor Sapego
• Reporter: Micky Loo
• Created: 01/Mar/22 18:31
• Updated: 29/Mar/22 06:48

Description

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

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"));

 

This functionality behaves as expected with using thick client and the events are batched.