Apache Spark上的Twitter流行标签
我对apache Spark是新手。我试图运行https://github.com/prabeesh/sparktwitteranalysis/tree/0.2.0示例，但控制台给出了以下错误：
WARN scheduler.TaskSchedulerImpl: Initial job has not accepted any resources; check your cluster UI to ensure that workers are registered and have sufficient memory
我已经使用NC-LK 9999启动了服务器，并通过sbt/sbt包编译了代码
并使用sbt/sbt'run spark://localhost:9999
删除了代码
这个错误的原因是什么？如何解决它
提前谢了。
共有1个答案
正如消息中提到的，工作人员没有在集群中注册，或者他们没有足够的内存来运行任务。从浏览器转到群集UI页面，并确保正确配置了工作节点。如果节点正在工作，那么尝试增加它们的可用内存。
-
我正在尝试使用apache spark和Scala获得twitter流行标签。我能够打印这些标签，但是当我开始使用reduce函数计算这些标签时，我得到了以下错误 Network.ConnectionManager：选择器线程中断！
-
有人能帮我解决这个问题吗？ 谢谢：）
-
我正在用Kafka设计一个spark流媒体应用程序。我有以下几个问题：我正在将数据从RDBMS表流式传输到kafka，并使用Spark consumer来使用消息，并使用Spark-SQL进行处理 问题：1。我将数据从表中流式传输到kafka as（键作为表名，值作为JSON记录形式的表数据）——这是正确的体系结构吗？ 这种数据库流的架构和设计是否正常，我如何解决转换问题中的转换？ 你好Piyus
-
我有一个基于maven的scala/java混合应用程序，可以提交spar作业。我的应用程序jar“myapp.jar”在lib文件夹中有一些嵌套的jar。其中之一是“common.jar”。我在清单文件中定义了类路径属性，比如。Spark executor抛出在客户端模式下提交应用程序时出错。类（com/myapp/common/myclass.Class）和jar（common.jar）在那里
-
Twitter标准库 Twitter最重要的标准库是Util 和 Finagle。Util 可以理解为Scala和Java的标准库扩展，提供了标准库中没有的功能或已有功能的更合适的实现。Finagle 是我们的RPC系统，核心分布式系统组件。 Futures已经在并发一节中简单讨论过。它是调异步处理的中心机制，渗透在我们代码库中，也是Finagle的核心。Futures允许组合并发事件，简化了高并
-
通常，当我使用twitter流api时，我可以直接从以下位置访问标签： 推特- 当用tweepy搜索关于关键词/标签的推文时，它会下载一个＜code＞ 当我搜索实体/主题标签时，我在作者下找到了第一个（我寻找的）。 推特- 这很奇怪。 “标签”位于 推特- 看起来像这样： 当我试图从 推特- 在循环中： 结果:hashtags是一个空字符串.. 使用时： 推特- 生成此错误: 我记得我最后一次和最