pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
refs: https://github.com/apache/pekko/actions/runs/12837234599/job/35800491988?pr=1724#step:7:5795 ```scala 01-17 21:46:48.292] [info] - must respect the throughput setting *** FAILED *** (10 seconds, 46 milliseconds) [01-17 21:46:48.292] [info] DispatcherActorSpec.this.convertToCheckingEqualizer[scala.Long](latch.getCount()).===[scala.Long](0L)(DispatcherActorSpec.this.typeCheckedConstraint[scala.Long, scala.Long](org.scalactic.Equivalence.default[scala.Long], scala.
I'm seeing the following occasional stack trace in production: ``` java.lang.IllegalArgumentException: requirement failed at scala.Predef$.require(Predef.scala:324) at org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:105) at org.apache.pekko.dispatch.TaskInvocation.run(AbstractDispatcher.scala:59) at org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$PekkoForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:57) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387) at java.base/java.util.concurrent.ForkJoinPool.helpJoin(ForkJoinPool.java:2076) at java.base/java.util.concurrent.ForkJoinTask.awaitDone(ForkJoinTask.java:423) at java.base/java.util.concurrent.ForkJoinTask.invokeAll(ForkJoinTask.java:750) ......
Forming a cluster with Akka nodes requires the deserialization of cluster messages sent by the Akka. This commit fixes the following exception that occurs during deserialization. ``` [akka://[email protected]:2551] with serializer...
Motivation: Currently, I have to use the `unfoldReosurce()` to integrate with a blocking queue. I think it would be nice to have this out of the box.
Our nightlies and link validation sometimes fail when it is ran on a GitHub Actions running that is blocked from repository.apache.org. Infra seems open to create per-project buckets for the...
We currently use between about 45-115 hours of GitHub Actions per day (https://github.com/apache/pekko/actions/metrics/usage, https://infra-reports.apache.org/#ghactions), and some jobs that are ran as part of PR validation can take a long time...
https://github.com/apache/pekko/actions/runs/12632585611/job/35196562037 Possibly related to #1679 ``` org.apache.pekko.remote.RemoteTransportException: Startup failed at org.apache.pekko.remote.Remoting.org$apache$pekko$remote$Remoting$$notifyError(Remoting.scala:174) at org.apache.pekko.remote.Remoting.start(Remoting.scala:250) at org.apache.pekko.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:274) at org.apache.pekko.actor.ActorSystemImpl._start$lzyINIT1(ActorSystem.scala:1043) at org.apache.pekko.actor.ActorSystemImpl._start(ActorSystem.scala:1039) at org.apache.pekko.actor.ActorSystemImpl.start(ActorSystem.scala:1062) at org.apache.pekko.actor.ActorSystem$.apply(ActorSystem.scala:283) at org.apache.pekko.actor.ActorSystem$.apply(ActorSystem.scala:327) at org.apache.pekko.actor.ActorSystem$.apply(ActorSystem.scala:301) at org.apache.pekko.remote.classic.RemotingSpec.selectionAndBind$1(RemotingSpec.scala:790) at...
https://github.com/apache/pekko/actions/runs/12612621246/job/35149558293?pr=1678#step:7:10560 I think we should wait a little when do `disassociate` ```scala org.apache.pekko.remote.RemoteTransportException: Startup failed at org.apache.pekko.remote.Remoting.org$apache$pekko$remote$Remoting$$notifyError(Remoting.scala:174) at org.apache.pekko.remote.Remoting.start(Remoting.scala:250) at org.apache.pekko.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:274) at org.apache.pekko.actor.ActorSystemImpl._start$lzyINIT1(ActorSystem.scala:1043) at org.apache.pekko.actor.ActorSystemImpl._start(ActorSystem.scala:1039) at org.apache.pekko.actor.ActorSystemImpl.start(ActorSystem.scala:1062) at org.apache.pekko.actor.ActorSystem$.apply(ActorSystem.scala:283) at...
There are : ``` org.apache.pekko.japi.Function ``` and ``` org.apache.pekko.japi.function.Function ``` we should deprecate all of it in `org.apache.pekko.japi.Function` and remove it in the next release.