Hello,
I’m upgrading my Akka project to 2.6.1 and Scala 2.13. I’m using java 11.
I have some problems around my upgrade, one of these I created a simple test unit:
public class SourceTimeout {
private static Logger logger = LoggerFactory.getLogger(SourceTimeout.class);
@Test
public void sourceTimeout() throws InterruptedException, ExecutionException, TimeoutException {
final ActorSystem system = ActorSystem.create("QuickStart");
Source.maybe()
.completionTimeout(Duration.ofSeconds(1))
.runWith(Sink.head(), system)
.toCompletableFuture()
.get(3, TimeUnit.SECONDS);
}
I receive these message
[ERROR] [01/10/2020 17:05:13.190] [QuickStart-akka.actor.default-dispatcher-4] [akka://QuickStart/system/Materializers/StreamSupervisor-0/flow-0-0-headSink] Error during preStart in [CompletionTimeout]: path parameter: Invalid path '': path has a leading, trailing, or two adjacent period '.' (use quoted "" empty string if you want an empty element)
com.typesafe.config.ConfigException$BadPath: path parameter: Invalid path '': path has a leading, trailing, or two adjacent period '.' (use quoted "" empty string if you want an empty element)
at com.typesafe.config.impl.PathParser.parsePathExpression(PathParser.java:170)
at com.typesafe.config.impl.PathParser.parsePathExpression(PathParser.java:74)
at com.typesafe.config.impl.PathParser.parsePath(PathParser.java:61)
at com.typesafe.config.impl.Path.newPath(Path.java:230)
at com.typesafe.config.impl.SimpleConfig.hasPathPeek(SimpleConfig.java:87)
at com.typesafe.config.impl.SimpleConfig.hasPath(SimpleConfig.java:99)
at akka.dispatch.CachingConfig.hasPath(CachingConfig.scala:99)
at akka.dispatch.Dispatchers.lookupConfigurator(Dispatchers.scala:142)
at akka.dispatch.Dispatchers.lookup(Dispatchers.scala:120)
at akka.stream.impl.PhasedFusingActorMaterializer.executionContext$lzycompute(PhasedFusingActorMaterializer.scala:417)
at akka.stream.impl.PhasedFusingActorMaterializer.executionContext(PhasedFusingActorMaterializer.scala:416)
at akka.stream.impl.PhasedFusingActorMaterializer.scheduleOnce(PhasedFusingActorMaterializer.scala:438)
at akka.stream.stage.TimerGraphStageLogic.scheduleOnce(GraphStage.scala:1633)
at akka.stream.impl.Timers$Completion$$anon$2.preStart(Timers.scala:85)
at akka.stream.impl.fusing.GraphInterpreter.init(GraphInterpreter.scala:306)
at akka.stream.impl.fusing.GraphInterpreterShell.init(ActorGraphInterpreter.scala:593)
at akka.stream.impl.fusing.ActorGraphInterpreter.tryInit(ActorGraphInterpreter.scala:701)
at akka.stream.impl.fusing.ActorGraphInterpreter.preStart(ActorGraphInterpreter.scala:750)
at akka.actor.Actor.aroundPreStart(Actor.scala:544)
at akka.actor.Actor.aroundPreStart$(Actor.scala:544)
at akka.stream.impl.fusing.ActorGraphInterpreter.aroundPreStart(ActorGraphInterpreter.scala:690)
at akka.actor.ActorCell.create(ActorCell.scala:637)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:509)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:531)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:294)
at akka.dispatch.Mailbox.run(Mailbox.scala:229)
at akka.dispatch.Mailbox.exec(Mailbox.scala:242)
at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)
Can you help me?
Thank you very much
type or paste code here