hi Reza
thx for the additional workaround! Best regards, I.P. ---------- Původní e‑mail ---------- Od: Reza Taroosheh <[email protected]> Komu: [email protected], [email protected] Datum: 1. 11. 2026 21:24:52 Předmět: Re: Re: Issue #2: ContinuousQueryWithTransformer on an ATOMIC cache problem "Hi, A simpler workaround for this issue: add a remote filter annotated with @IgniteAsyncCallback that accepts all events, for example: @IgniteAsyncCallback public class AcceptAll implements CacheEntryEventSerializableFilter<Integer, Object> { @Override public boolean evaluate(CacheEntryEvent<? extends Integer, ?> evt) { return true; } } qry.setRemoteFilterFactory(FactoryBuilder.factoryOf(new AcceptAll())); With it, the transformer result is converted outside the topology lock, so the class can be registered there. With this filter, the ticket test passes on master. Note that the listener is then also called from the async callback pool. The ticket is https://issues.apache.org/jira/browse/IGNITE-29227, and a patch is under review: https://github.com/apache/ignite/pull/13769 Thanks, Reza On Thu, Oct 29, 2026 at 9:45 AM <[email protected]> wrote: > > Hi Reza > > Many thanks for the quick verification and the tickets. > > Best regards, > I.P. > > ---------- Původní e‑mail ---------- > Od: Reza Taroosheh <[email protected]> > Komu: [email protected], [email protected] > Datum: 28. 10. 2026 23:21:22 > Předmět: Re: Issue #2: ContinuousQueryWithTransformer on an ATOMIC cache problem > > Hi I.P., > > Thank you for this report as well. > > I confirmed it: your reproducer fails on 2.18.0, and a new test fails the same way on master. The listener on another node receives none of the partition's events, while the same test on a TRANSACTIONAL cache receives all of them. > > One addition to the workaround: in my test, registering the result class with toBinary() helped only when it ran on the key's primary node, where the transformer runs. Registering it on the other node did not help. > > Ticket: https://issues.apache.org/jira/browse/IGNITE-29227 > > If a committer agrees with the issue, I'm happy to work on a fix. > > Best regards, > Reza Taroosheh > > On Wed, Oct 28, 2026 at 1:38 PM <[email protected]> wrote: > > hi devs > > So here is the second one: on an ATOMIC cache, a continuous query, whose transformer returns an unregistered class, holds a partition's events. > > A README.md with a detailed description is attached in the reproducer as well. > > Please have a look and if you confirm a defect, please provide a JIRA ticket number. > Thank you in advance. > > Best regards, > I.P. "
