我的 Spark 的 Worker 无法连接 Master.Akka 有问题吗?
我想将 Spark Standlone 模式安装到我的两个虚拟机的集群中. 使用 spark-0.9.1-bin-hadoop1 版本，我在每个 vm 中都成功执行了 spark-shell.我按照官方文档制作了一个vm(ip:xx.xx.xx.223) 作为 Master 和 Worker 并使另一个 (ip:xx.xx.xx.224) 仅作为 Worker. 但是224-ip vm无法连接
..
akka相关内容
play 框架 2.1 - 调度异步任务
在 play 的 2.0.x 文档中，您可以看到如何安排异步任务: http://www.playframework.org/documentation/2.0.4/ScalaAkka Akka.system.scheduler.schedule(0 秒, 30 分钟, testActor, "tick") 你怎么能用最近重新发布的 Play 2.1 达到同样的效果??? 整个 a
..
按需演员获取或创建
我可以用 actorOf 创建演员，并用 actorFor 查看他们.我现在想通过一些 id:String 获取一个演员，如果它不存在，我希望它被创建.像这样: def getRCActor(id: String):ActorRef = {Logger.info("获取演员 %s".format(id))var a = system.actorFor(id)如果(a.isTerminated)
..
如何从 Java 中的 Java 列表创建 scala.collection.immutable.Seq?
我正在尝试让 Akka 在我的 Java 项目中运行，但我被 Scala 的 Seq 类型的一个小问题所困扰.我可以将我的 ActorRef 的 Java 列表转换为 scala.collection.Seq，但是我尝试使用的 Akka API 需要一个 scala.collection.immutable.Seq.我怎样才能制作一个? 代码: static class Router ex
..
如何从演员本身中获取 Akka 演员的姓名?
所以，如果我有演员，我可以给它起个名字.但是，我可以在内部访问该名称吗?示例: class Actorz 使用 ActorLogging { 扩展 Actorval actorName =//??什么函数def 接收 = {情况 x =>log.debug(actorName+": Received Message: "+x)}}val actor = system.actorOf(Props[
..
使用 akka 流有条件地跳过流
我正在使用 akka 流，并且我有一段我需要有条件地跳过的图表，因为流程无法处理某些值.具体来说，我有一个接受字符串并发出 http 请求的流，但是当字符串为空时，服务器无法处理这种情况.但我只需要返回一个空字符串.有没有办法做到这一点而不必通过 http 请求知道它会失败?我基本上有这个: val source = Source("1", "2", "", "3", "4")val httpR
..
我怎样才能将未来的未来变成一个未来的对象?
环境:Akka 2.1，scala 版本 2.10.M6，JDK 1.7，u5 现在是我的问题:我有: future1 = Futures.future(new Callable>(){...});未来 2 = ?扩展对象；Future.sequence(future1, future2).onComplete(...) 现在在第一行，我有一个 Future 对象的 Future，有没有
..
Akka 2.1 最小远程角色示例
编辑注意，我需要对此https://github.com/akka/akka/commit/ce014ece3568938b2036c4ccfd21b92faba69607#L13L6 使接受的答案适用于 AKKA 2.1，这是 akkas 主页上的稳定发行版！ 我已经阅读了我可以在 AKKA 上找到的所有教程，但我没有发现任何“开箱即用"的教程. 使用eclipse，我想创建2个程序
..
如何在 PlayFramework 中使用 Akka Streams SourceQueue
我想使用 SourceQueue 将元素动态推送到 Akka Stream 源中.播放控制器需要一个 Source 才能使用 chunked 方法流式传输结果. 由于 Play 在幕后使用自己的 Akka Stream Sink，我无法使用 Sink 自己实现源队列，因为源将在被 chunked 方法使用之前被消耗(除非我使用跟随黑客). 如果我使用反应流发布者预先实现源队列，我就能让它工
..
如何将我的 Spray API 部署到生产环境中?
我正在考虑如何将我已经在本地测试过的 rest api 部署到云的过程，比如说像亚马逊这样的基础设施即服务(而不是像 Heroku 这样的平台即服务). 我在本地环境中设置并运行了 sbt，但我的问题是我应该如何在生产环境中部署它? 定义一个过程，在这个过程中，devops 从 git repo 中提取最新的更改，然后简单地执行 sbt run? 我想知道使用scala+spra
..
不同的 Scala Actor 实现概述
我正在尝试找到“正确"的演员实现.我意识到有很多它们，选择一个有点令人困惑.就我个人而言，我对远程演员特别感兴趣，但我想完整的概述会对许多其他人有所帮助.这是一个非常普遍的问题，所以请随意回答您所了解的实现. 我了解以下 Scala Actor 实现 (SAI).请补充缺少的. Scala 2.7(不同于) Scala 2.8 阿卡 (http://www.akkasource.o
..
Scala 演员 - 最糟糕的做法?
我对在 Scala 中使用 actor 感到有点不安全.我已经阅读了有关如何做事的文档，但我想我还需要一些 DON'T 规则才能随意使用它们.我想我害怕我会以错误的方式使用它们，我什至不会注意到它. 你能想到什么，如果应用，会导致破坏 Scala actor 带来的好处，甚至是错误的结果? 解决方案 尽可能避免!?.您将获得一个锁定的系统！ 总是从 Actor 子系统线程发
..
需要类类型，但找到了 T
由于某种原因我无法创建演员(这是我的类层次结构的简单版本): abstract class Class1[T 上下文 actorOf Props(new T(x)) }//错误}抽象类 Class2[U 但是有一个错误说class type required but T found. 解决方案 您不能使用类型参数 T 调用 new T(x).T 可能没有这样的构造函数: class
..
Play Framework 2.0 在服务器启动时安排 Akka Actor
我有一个 Akka actor，它验证随机数据并根据该数据的显示时间对其进行一些更改并更新它.目前我正在做的是在控制器中使用此代码: static ActorRef instance = Akka.system().actorOf(new Props(ValidateAndChangeIt.class));静止的 {Akka.system().scheduler().schedule(Durat
..
如何在akka的发送和接收动作中添加日志功能
现在，我被要求在 akka 的 actor 中添加日志记录功能. 收到消息后，在处理之前，应将此消息写入日志.并且在发送一条消息之前，应该先记录这条消息. 我认为我应该覆盖 Actor 中的 receive 和 send 函数.假设我创建了一个扩展 Actor 的特征 actorlog.而 myActor 类扩展了 actorlog.但是在 myActor 中，我需要覆盖 receiv
..
使用 Akka Stream 从数据库流式传输记录
我有一个使用 Akka 的系统，该系统当前通过消息队列处理传入的流数据.当一条记录到达时，它被处理，mq 被确认并传递记录以在系统内进一步处理. 现在我想添加对使用数据库作为输入的支持. 输入源能够处理数据库的方法是什么(应该以接收器可以处理的速度流式传输 > 100M 记录 - 所以我假设是反应性/akka-streams?)? 解决方案 Slick Library 流畅的
..
将 Akka 的 Future[A] 转换为 Future[Either[Exception,A]]
Akka 中(或 Scala 2.10 的标准库中)是否有方法可以将 Future[A] 转换为 Future[Either[Exception,A]]?我知道你可以写 f.map(Right(_)).recover {情况e:异常=>左(e)} 这似乎是一项很常见的任务，我不知道我是否忽略了一些东西.我对 Scala 2.9/Akka 和 Scala 2.10 的答案很感兴趣. 解决方
..
为什么 Spark 1.6 不使用 Akka?
当我阅读Master 类，receiveAndReply 方法似乎没有使用 Akka.[参见这里.] 为什么不使用 Akka ?他们用什么代替了 Akka? 解决方案 使 Spark 独立于 Akka 背后的动机在 SPARK-5293 这是 Akka 相关问题的总括性任务. 引用原始描述: Spark 依赖于 Akka，[因此] 用户不可能依赖不同的版本，而且我们过去曾
..
如何在没有 Akka 的情况下实现 actor 模型?
如何在没有 Akka 的情况下实现简单的 actor?对于许多(非固定计数)actor 实例、绿色线程、IoC(生命周期、基于 Props 的工厂、ActorRef 的)、监督、背压等，我不需要高性能.只需要顺序性(队列)+ 处理程序 + 状态+ 消息传递. 作为一个副作用，我实际上需要基于actor的小型管道(带有递归链接)+一些并行actor来优化DSP 算法计算.它将在没有传递依赖关系
..
使用 uberjar 进行部署时覆盖 Typesafe 配置中的多个配置值
我有一个 Akka 应用程序，它使用在 resource/application.conf 中定义的多个配置值(IP 地址、端口号).我正在使用 sbt-assembly 插件来创建一个 uber jar，然后部署这个 jar. 有没有办法通过使用 uber jar 之外的另一个文件来覆盖整个 application.conf 文件?(即，使用新 conf 文件中的值) 解决方案 有
..