我试图通过使用akka流参考文件将音频流从服务A发送到服务B (akka-streams库版本: 2.6.3)。一切都运行得很好,除了每月一次在akka流引用中抛出异常(每天使用该服务的次数约为50k )外,我找不到问题的原因。
错误的堆栈跟踪如下:
Caused by: java.lang.IllegalStateException: [SourceRef-46] Saw RemoteStreamCompleted(37) while in state UpstreamTerminated(Actor[akka://system-name@serviceA:34363/sys
我有一个想要测试的控制器操作,但是我得到了下面的错误。我觉得我可能遗漏了一些小东西,但又不能完全弄清楚它是什么。我写了一些小代码来帮助说明这个问题。
在更多的上下文中,我希望能够为控制器提供模拟依赖项,这就是为什么我要完全接管它的实例化。
java.lang.UnsupportedOperationException: NoMaterializer does not provide an ExecutionContext
[info] at play.api.test.NoMaterializer$.executionContext(Helpers.scala:661)
[info]
我正在尝试运行在ZeroMQ集群上使用YARN的Spark应用程序。
Executor的日志包含以下消息:
16/05/24 11:42:09 INFO storage.MemoryStore: Block broadcast_2 stored as values in memory (estimated size 67.2 KB, free 530.2 MB)
16/05/24 11:42:09 INFO util.RecurringTimer: Started timer for BlockGenerator at time 1464090129200
16/05/24 11:42:09
我正在试着测试演员,那就是使用。这种情况是,数据库处于脱机状态,它应该向另一个参与者发送一个通知,说明数据库不可用。
在创建子参与者期间,它将数据持久化到数据库,它引发以下错误:
akka.actor.ActorInitializationException: akka://StoreTestOffline/user/OfflineStoreActor/StoreChilid: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:202)
我正在尝试在我正在做的纱线上安装火花作业服务器。
./bin/server_package.sh ec2
当我尝试使用/tmp/jobserver时,这会在./sever_start.sh中形成一个文件夹
我收到这个错误
Uncaught error from thread [JobServer-akka.actor.default-dispatcher-2] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[JobServer]
Uncaught error fr
我有个演员靠藏东西。存储需要UnboundedDequeBasedMailbox。是否可以将Bounded邮箱存储在一起?
正如阿诺所指出的,我的设置是:
Actor with UnrestrictedStash with RequiresMessageQueue[BoundedDequeBasedMessageQueueSemantics]
和配置:
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = INFO
daemonic = on
actor {
我想编写一个Scala客户端,它通过与TLS的tcp连接来讨论专有协议。
基本上,我想用Scala重写Node.js中的以下代码:
var conn_options = {
host: endpoint,
port: port
};
tlsSocket = tls.connect(conn_options, function() {
if (tlsSocket.authorized) {
logger.info('Successfully established a connection');
//
我将我的星火作业从本地的笔记本电脑提交到一个远程独立的星火集群( spark ://IP:7077)。本报告已成功提交。但是,我没有得到任何输出,过了一段时间它就失败了。当我检查集群中的工作人员时,会发现以下异常:
Exception in thread "main" akka.actor.ActorNotFound: Actor not found for: ActorSelection[Actor[akka.tcp://sparkDriver@localhost:54561/]/user/CoarseGrainedScheduler]
当我在本地系统( local *)上运
我遇到了一个akka.ConfigurationException: Akka JAR version [2.1.0] does not match the provided config version [2.2.3]。我的猜测是,不知何故,$SCALA_HOME/lib/akka-actors.jar正把它和SBT管理的Akka JAR一起放到类路径上。
我创建了一个简单的独立SBT项目来演示这个问题(参见下面)。我的$SCALA_HOME指向Scala2.10.3。在Build.scala中,我显式地将scalaHome设置为$SCALA_HOME
project/Build.scala
当我试图从scala Playmework发送邮件时,我得到了以下错误:
[ERROR] [10/10/2013 13:31:16.263] [play-akka.actor.default-dispatcher-75] [TaskInvocation] Sending the email to the following server failed : smtp.gmail.com:25
org.apache.commons.mail.EmailException: Sending the email to the following server failed : smtp.gmail.c
我正在尝试实现曼宁的"Akka in Action“一书中的"Up and Running" example的Java版本。它是一个简单的基于Actor模型的Http服务器,用于保存(仅在内存中)和检索一些事件。我对保存事件没有任何问题。但是在我的参与者系统中查询事件(所有事件)时,我确实遇到了一个问题。 这是所有TicketSeller的父参与者(后来负责管理每个事件的状态)的相关代码(我放了三个点,而不是我认为与我的问题无关的代码)。 public class BoxOffice extends AbstractActor {
...
priva
我面临着向集群提交作业的问题,无论是通过星星之交还是从java代码。作业不断失败,stderr日志(在SPARK_HOME/work/app_id下)始终显示相同的错误:
15/10/08 23:04:39 WARN ReliableDeliverySupervisor: Association with remote system [akka.tcp://sparkDriver@masternode:53411] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp
我是第一次接触lagom scala。创建了一个简单的crud来学习它的关键概念。首先,我使用sbt clean compile编译了我的代码,它成功地编译了代码。在那之后,我尝试使用sbt clean runAll命令运行该项目。有时服务启动时没有任何问题。但有时我发现一条消息说 java.util.concurrent.TimeoutException: The first element has not yet passed through in 5000 milliseconds.
at akka.stream.impl.Timers$Initial$$anon$1.onTi
应用程序依赖项包括:
com.typesafe.akka#akka-actor_2.10;2.3.7
org.reactivemongo#reactivemongo_2.10:0.10.5.0.akka23
org.reactivemongo#play2-reactivemongo_2.10:0.10.5.0.akka23
在启动应用程序时,我得到了几个1.3.1版的喷射库
java.lang.AbstractMethodError
at akka.actor.ActorCell.create(ActorCell.scala:580)
at akka.actor.ActorCe
我正在尝试运行一个在localhost (9000)上使用sbt的开源工具。但是,当我试图将一个文件(.arrf)上传到工具(这是该工具需要的第一件事)时,我会得到一个FileNotFound错误,如下所示。
我对Scala没有经验,对JS的经验也有限,但据我所知,在将文件上传到服务器时存在一个问题。我尝试使用不同大小的文件和原始作者使用的文件。我查看了代码,文件上传由一个FileUploadService.scala类处理,如下所示,
class FileUploadService(serviceSavePath: String) {
val basePath = if (s
我正在使用play Mailer模块。我要去mailerClient.send(email).找NullPointerException
发送邮件代码
import javax.inject.Inject;
import play.libs.mailer.Email;
import play.libs.mailer.MailerClient;
public class MailerService {
@Inject MailerClient mailerClient;
public void sendEmail() {
Email email = new Ema