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 回答