2016-11-22 3 views
1
ClusterGroup clusterGroup = ignite.cluster().forNodeIds(invalidNodeIds) 
final Map<IgniteUuid, ComputeTaskFuture<Object>> computeTaskFutures = ignite.compute(clusterGroup).activeTaskFutures(); 

когда фиктивные invalidNodeIds передаются в, даже если подложке ClusterGroupAdapter имеет пустой узел идентификаторы (Set идентификаторы) объект, я вижу, действительные фьючерсы возвращаются. Разве это не так?ComputeTaskFuture карта возвращает фьючерсы на карту, даже если недействителен кластер NodeId указан

Благодаря

ответ

2

IgniteCompute.taskFutures() является локальной операцией, то есть он возвращает фьючерсы на задачи, которые были выполнены в текущем узле. Сказав, что кластерная группа не применима к этому методу.

+0

Я думал, что он возвращает фьючерсы для всех задач в указанной группе кластеров. Я вижу, что в документации говорится иначе: «Возвращает задачи для активных задач, запущенных на локальном узле». , Тем не менее, есть ли способ получить фьючерсы на всех узлах? Или даже указать, на каком узле это работает, потому что многие наши работники - просто тупые демон-демоны, готовые принять работу. –

+0

Я вижу последний комментарий на http://stackoverflow.com/questions/40592412/listing-current-ignite-jobs-and-cancelling-them, который может быть полезен. Кроме того, я размышлял над трансляцией приведенного выше фрагмента кода ко всем узлам и сбору результатов –

 Смежные вопросы

  • Нет связанных вопросов^_^