[jira] [Created] (IGNITE-12798) Failed to start continuous query when use client node in IDEA

[Anton Vinogradov (Jira)]

RangerZhou created IGNITE-12798:
-----------------------------------

             Summary: Failed to start continuous query when use client node in IDEA
                 Key: IGNITE-12798
                 URL: https://issues.apache.org/jira/browse/IGNITE-12798
             Project: Ignite
          Issue Type: Bug
          Components: cache
    Affects Versions: 2.7.6
            Reporter: RangerZhou
         Attachments: Exception.log

I start ignite server by ./ignite.sh, start a ignite client by java code, and execute a continuous query with java in IDEA, but exception like this:

Exception in thread "main" javax.cache.CacheException: Failed to start continuous query.

Caused by: class org.apache.ignite.IgniteCheckedException: TOFListener

My client code as below: 

public class TOFListener {
 public static void main(String[] args) {
 IgniteConfiguration cfg = new IgniteConfiguration();
 cfg.setClientMode(true);

 Ignite ignite = Ignition.start(cfg);
 IgniteCache<String, Object> cache = ignite.getOrCreateCache("TOFCache");

 // Creating a continuous query.
 ContinuousQuery<String, Object> qry = new ContinuousQuery<>();
 qry.setInitialQuery(new ScanQuery<>((k, v) -> "name".equals(k) || "shoulderWidthStdDev".equals(k)));
 qry.setLocalListener((evts) -> evts.forEach(e ->
 System.out.println("UpdatedValue, [key=" + e.getKey() + ", val=" + e.getValue() + "]")));
 qry.setRemoteFilterFactory(() -> evts -> evts.getKey().equals("name") || evts.getKey().equals("shoulderWidthStdDev"));

 QueryCursor<Cache.Entry<String, Object>> cursor = cache.query(qry);

 }

}

 

The exception uploaded the attachment



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