Continuous Query

Hi there.I found that for Ignite V 1.5.6 and 1.5.7 Continuous query stop working while it worked for V1.5.3.My code follows the manual:// Create new continuous query.ContinuousQuery query = new ContinuousQuery(); query.setInitialQuery(sql); query.setRemoteFilter(new

Re: index and query org.apache.ignite.spark.IgniteRDD[String,org.apache.spark.sql.Row]

Hi guys, Thanks for pointing me to the right direction; Provided links about binary marshaller was quite useful; Unfortunately i was not able to achieve my final goal; I get a GridDhtPartitionsExchangeFuture when i call cache.savePairs method; Here is a full stack: scala>

Re: @QuerySqlField for collections

Hi Vladimir, i tried with java.util.ArrayList[String], got following exception: scala> val result = cache.sql("select t1.* from TRow1 as t1").count 16/03/07 03:23:09 WARN TaskMemoryManager: leak 8.3 MB memory from org.apache.spark.unsafe.map.BytesToBytesMap@bb96887 16/03/07 03:23:09 ERROR

Re: IniteCache: How to ensure cache is 'rebalanced' when a node leaves topology?

You need to set number of backups to 1 to guarantee that there won't be data loss when a node leaves the cluster. Use CacheConfiguration.setBackups(1) method for that. -- Denis On Sunday, March 6, 2016, techbysample wrote: > Forum, > > Background: > > I started an

IniteCache: How to ensure cache is 'rebalanced' when a node leaves topology?

Forum, Background: I started an IgniteCache using the following configuration: Ignition.setClientMode(true); try (Ignite ignite = Ignition.start()) { CacheConfiguration cacheCfg = new

Re: Continuously running jobs

What do you think, is Ignite the right tool for me? Am I better off with Akka? -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Continuously-running-jobs-tp3376p3378.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Two Ignite Clusters formed after network disturbance

Hi I am using ignite as a fault tolerant compute and cache engine, i have 4 nodes forming a cluster. one of the nodes contain singleton cluster services that execute different jobs on the different cluster nodes. once in a while a network disturbance occur, for example node 4 network disconnected

Continuously running jobs

Info: I used spaces to indent my examples, hope it displayed correctly. I am *new to Ignite* and I would be really happy, If you could give me some help. I am working on a* distributed web crawler* in Java8, would like to use ignite to distribute jobs across the available nodes. A single job

Re: Semaphore blocking on tryAcquire() while holding a cache-lock

Vlad and all (esp Val and Anton V.), I reviewed the PR. My comments are in the ticket. Anton V. there is a question regarding optimized-classnames.properties. Can you please respond in ticket? --Yakov 2016-02-29 16:00 GMT+06:00 Yakov Zhdanov : > Vlad, that's great! I