Apache Stormでノード上で実行中のタスクを特定する方法

Question

同じノードで実行されている別のボルトに1つのボルトのエミッションを伝播させるCustomGroupingを書きたいと思います。 localOrShuffleGroupingは、同じプロセス内でタプルを保持しようとすることによってこれを部分的に達成します。私はさらに一歩進んで、マシンレベルで縛りをつけたいと思っています。ここでの主な目的は、ネットワークの待ち時間を短縮し、スループットを向上させることです（帯域幅に制限されないため）。

TopologyContextからgetThisWorkerTasks（）を呼び出すと、同じワーカープロセスで実行されているタスクIDを取得できることにご注意ください。しかし、私は同じノード（他のプロセスのものを含む）上で実行されているすべてのtaskIDを取得する方法を見つけることができませんでした。

Answer 1

私たちはこれを行うAPIがないと思います。これを行うための1つの方法は、ダウンストリームのボルトがホスト名（またはIP）とタスクIDをすべてのアップストリームボルト（グローバルストリーミングによって）に送信し、アップストリームボルトのこの情報を使用してタプルを送信するのに最適なボルトを決定することです。ホスト名を送信するには、tick tupleを使用できます。