Partitions, where a key stored, will nut be migrated during task executing.
By java doc[1]: The data of the partition where affKey is stored will not be migrated from the target node while the job is executed. You not need to worried, data will be situated in the same node and will migrate after. [1]: https://github.com/apache/ignite/blob/master/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java On Fri, Aug 12, 2016 at 9:31 AM, Kamal C <[email protected]> wrote: > Hi all, > > I'm using IgniteCompute#affinityRun(cacheName, key, runnable) to > execute the tasks where the data resides. If cache rebalance happens in the > middle of task execution, then the task is not aware of the rebalance. Is > there any provision available to interrupt the task ? > > I would like to throw `ComputeJobFailOverException` if interrupted. > > Regards, > Kamal C >
