我使用的是一个有3个节点的MapR (YARN)集群。我正在尝试在集群上部署6个Samza作业,以便对数据流进行一些处理。所有作业都是正确的。我尝试并行部署2-3,它们都有效。但是,当我并行部署所有6个Samza作业时,我看到以下日志。任务将继续运行,并且不会产生预期的输出数据流。

我的ResourceManager web仪表板上节点的状态如下-

有谁能建议如何解决这个问题。我认为可能应用程序没有足够的资源来并行运行所有这些应用程序。我可以试一下什么变化?
发布于 2016-06-19 21:21:27
no more pending requests in queue.这条消息意味着在你的Kafka主题中还有更多的消息。
https://stackoverflow.com/questions/37736631
复制相似问题