我有一个 spark 流应用程序,它运行得非常好,直到昨天,突然遇到这些警告。我有相同的环境并使用相同的代码。以下是警告:
05/09 17:13:03 INFO ExecutorAllocationManager:请求 16 个新执行器,因为任务积压(新的期望总数为 31) 16/05/09 17:13:03 INFO ExecutorAllocationManager:请求 19 个新执行器,因为任务积压(新所需的总数为 50)
16/05/09 17:13:12 WARN YarnScheduler:初始作业未接受任何资源;检查您的集群 UI 以确保工作人员已注册并拥有足够的资源
16/05/09 17:13:27 WARN YarnScheduler: Initial job 没有接受任何资源;检查您的集群 UI 以确保工作人员已注册并拥有足够的资源
我在 cloudera 5.5 上使用 apache spark 1.6。快速启动虚拟机。集群上没有运行应用程序来消耗可用资源。
有什么配置可以做吗?
谢谢!