;>> 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
>>&
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
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
>>
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
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
>>>
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
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
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 <
>>&
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
;> 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 (
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
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
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
13 matches
Mail list logo