You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@ignite.apache.org by "Aditya (Jira)" <ji...@apache.org> on 2021/08/05 08:07:00 UTC

[jira] [Created] (IGNITE-15258) IgniteSourceTask code issue

Aditya created IGNITE-15258:
-------------------------------

             Summary: IgniteSourceTask code issue
                 Key: IGNITE-15258
                 URL: https://issues.apache.org/jira/browse/IGNITE-15258
             Project: Ignite
          Issue Type: Bug
            Reporter: Aditya


[https://github.com/apache/ignite-extensions/blob/master/modules/kafka-ext/src/main/java/org/apache/ignite/stream/kafka/connect/IgniteSourceTask.java#L167]

 

we have a 3 node setup, where 2 nodes are ignite servers and the other node is kafka connect source process which will be connected to those 2 nodes. So total 3 ignite nodes in baseline topology.

In the above code I've used custom class filter and set it via cacheFilterCls.

Now while executing queries on caches with "Replication" mode, the custom cache filter is working only on 3rd node but not on other 2 nodes.

In other words the custom filter is applied only for keys of cache that 3rd node is primary of. Seems the class is not running on other 2 nodes.

can someone please check this.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)