Problem with ScanQuery with filter on ClinetCache

[Prasad Kommoju]

Hi

I am having trouble getting ScanQuery to work with a filter from thin client.

I have attached a working minimal reproduction program (IntelliJ project zip 
export) , the ignite config file and the  part of the ignite logfile after 
running the query. The code is fashioned along the example in the documentation.

Here is the querying part of the code:

…
IgniteBiPredicate<String, Person> filter =
        (key, p) -> p.getName().equals(srchName);

try (QueryCursor<Cache.Entry<String, Person>> scnCursor =
             personCache.query(new ScanQuery<>(filter))) {
    scnCursor.forEach(
            entry -> System.out.println(entry.getKey() +
                    " " + entry.getValue()));
} catch (Exception e) {
    System.out.println("Scan query failed " + e.getMessage());
}

…

Any help in pointing out the problem will be greatly appreciated.


---------------------
Regards,
Prasad Kommoju

ScanQueryTest.java
Description: ScanQueryTest.java

default-config.xml
Description: default-config.xml

ignite-scanquery.log
Description: ignite-scanquery.log