[
https://issues.apache.org/jira/browse/IGNITE-12798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RangerZhou updated IGNITE-12798:
--------------------------------
Attachment: TOFListener.png
> 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
> Priority: Major
> Attachments: Exception.log, TOFListener.png
>
>
> 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)
