Apache Storm 1.0.3 から 2.2.0 にアップグレードしていますが、トポロジ タスクがすべてのワーカーで実行されておらず、Spout と同じワーカーでのみ実行されているという特有の問題に直面しています。
私は shuffleGrouping を使用しており、2 つのボルトと 1 つのスパウトの間に 6 つのワーカーと合計 51 のエグゼキューターを構成しています。トポロジを開始すると、6 つのワーカーすべてが期待どおりに開始されますが、スパウトを持つ 1 つのワーカーだけがすべての作業を行っています。
2.2.0 用に特別な構成が必要ですか。すべてのトポロジはバージョン 1.0.3 で正常に動作しています。
テストとして、Strom-starter から ExclamationTopology も実行していますが、1 つのワーカーだけがすべての作業を行っているという同じ問題が発生しています。
助けてくれてありがとう。
よろしく、