Re: Active tasks in cluster

2019-12-06 Thread Ilya Kasnacheev
;>> Thank you for the suggestion. I will try this. >>>>>>> >>>>>>> I am thinking to store the task future object in a (replicated)cache >>>>>>> against a jobId. If the node goes down as described in case (b), I will >>&

Re: Active tasks in cluster

2019-12-01 Thread Prasad Bhalerao
ou for the suggestion. I will try this. >>>>>> >>>>>> I am thinking to store the task future object in a (replicated)cache >>>>>> against a jobId. If the node goes down as described in case (b), I will >>>>>> get >>>>&g

Re: Active tasks in cluster

2019-11-26 Thread Prasad Bhalerao
t;> the >>>>> get method on it. >>>>> >>>>> But I am not sure about this approach, whether a future object can be >>>>> serialized and send it over the wire to another node and deserialize it >>>>> and >>

Re: Active tasks in cluster

2019-11-23 Thread Mikael
On Wed, Nov 20, 2019 at 5:27 PM Prasad Bhalerao mailto:prasadbhalerao1...@gmail.com>> wrote: Hi, I want to get the active tasks running in cluster (tasks running on all nodes in clus

Re: Active tasks in cluster

2019-11-23 Thread Prasad Bhalerao
ure object can be >>>> serialized and send it over the wire to another node and deserialize it and >>>> then invoke the get API on it. >>>> >>>> I will try to implement it tomorrow. >>>> >>>> Thanks, >>>> Prasad >>>

Re: Active tasks in cluster

2019-11-23 Thread Mikael
Futures()); Regards, Igor Belyakov On Wed, Nov 20, 2019 at 5:27 PM Prasad Bhalerao mailto:prasadbhalerao1...@gmail.com>> wrote: Hi, I want to get the active tasks running in cluster

Re: Active tasks in cluster

2019-11-23 Thread Prasad Bhalerao
Igor Belyakov >> wrote: >>> >>>> Hi Prasad, >>>> >>>> I think that you can use compute().broadcast() for collecting results >>>> of activeTaskFutures() from all the nodes: >>>> Collection>> result = >>>> ignite.c

Re: Active tasks in cluster

2019-11-20 Thread Denis Magda
ures() from all the nodes: >>> Collection>> result = >>> ignite.compute().broadcast(() -> ignite.compute().activeTaskFutures()); >>> >>> Regards, >>> Igor Belyakov >>> >>> On Wed, Nov 20, 2019 at 5:27 PM Prasad Bhalerao < >>&

Re: Active tasks in cluster

2019-11-20 Thread Prasad Bhalerao
results >> of activeTaskFutures() from all the nodes: >> Collection>> result = >> ignite.compute().broadcast(() -> ignite.compute().activeTaskFutures()); >> >> Regards, >> Igor Belyakov >> >> On Wed, Nov 20, 2019 at 5:27 PM Prasad Bhalerao < >&g

Re: Active tasks in cluster

2019-11-20 Thread Mikael
;> result = ignite.compute().broadcast(() -> ignite.compute().activeTaskFutures()); Regards, Igor Belyakov On Wed, Nov 20, 2019 at 5:27 PM Prasad Bhalerao mailto:prasadbhalerao1...@gmail.com>> wrote: Hi, I want to get the active tasks running in cluster (

Re: Active tasks in cluster

2019-11-20 Thread Prasad Bhalerao
PM Prasad Bhalerao < > prasadbhalerao1...@gmail.com> wrote: > >> Hi, >> >> I want to get the active tasks running in cluster (tasks running on all >> nodes in cluster) >> >> IgniteCompute interface has method "activeTaskFutures" which retu

Re: Active tasks in cluster

2019-11-20 Thread Igor Belyakov
Bhalerao < prasadbhalerao1...@gmail.com> wrote: > Hi, > > I want to get the active tasks running in cluster (tasks running on all > nodes in cluster) > > IgniteCompute interface has method "activeTaskFutures" which returns > tasks future for active tasks started on l

Active tasks in cluster

2019-11-20 Thread Prasad Bhalerao
Hi, I want to get the active tasks running in cluster (tasks running on all nodes in cluster) IgniteCompute interface has method "activeTaskFutures" which returns tasks future for active tasks started on local node. Is there anyway to get the task futures for all active tasks of who