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

當虛擬invalidNodeIds傳遞無效NODEID集羣,即使後盾ClusterGroupAdapter有(集ID)的對象,我看到返回有效的期貨空的節點ID映射期貨連。這不是錯的嗎?ComputeTaskFuture地圖返回時指定

由於

回答

2

IgniteCompute.taskFutures()是本地操作,即它返回期貨對於已經由當前節點執行的任務。話雖如此,羣集組不適用於此方法。

+0

我認爲它會返回指定羣集組內所有任務的期貨。我發現文檔中另有說明「獲取在本地節點上啓動的活動任務的將來任務。」 。也就是說,有沒有辦法在所有節點上獲得期貨?甚至可以指定運行哪個節點,..因爲我們的許多工作人員只是啞巴守護進程準備接受工作。 –

+0

我看到最後的評論在http://stackoverflow.com/questions/40592412/listing-current-ignite-jobs-and-cancelling-them可能是有用的。否則,我在想着將上面的代碼片段廣播到所有節點並收集結果 –