1

3 つのノードを持つ MapR (YARN) クラスターを使用しています。データ ストリームの処理のために、クラスターに 6 つの Samza ジョブをデプロイしようとしています。すべてのジョブは正しいです。2〜3個を並行してデプロイしてみましたが、動作します。ただし、6 つの Samza ジョブすべてを並行して展開すると、次のログが表示されます。タスクは引き続き実行され、期待される出力データ ストリームが生成されません。

ここに画像の説明を入力

ResourceManager Web ダッシュボードのノードのステータスは次のとおりです。 ここに画像の説明を入力

誰でもこれを解決する方法を提案できますか? アプリケーションには、それらすべてを並行して実行するのに十分なリソースがない可能性があると思います。どのような変更を試すことができますか?

4

1 に答える 1

0 
no more pending requests in queue.

このメッセージは、Kafka トピックにさらに多くのメッセージがあることを意味します。

于 2016-06-19T13:21:27.493 に答える