pjfanning commented on issue #2000: URL: https://github.com/apache/pekko/issues/2000#issuecomment-3148605180
One example of a failure with Java 24 (`sbt "stream-tests/testOnly *HubSpec*"`) ``` [info] HubSpec: Coroner Thread Count starts at 17 in org.apache.pekko.stream.scaladsl.HubSpec [info] MergeHub [info] - must work in the happy case (270 milliseconds) [info] - must notify new producers if consumer cancels before first producer (173 milliseconds) [info] - must do not throw exceptions when upstream completes normally (55 milliseconds) [info] - must notify existing producers if consumer cancels after a few elements (58 milliseconds) [info] - must notify new producers if consumer cancels after a few elements (86 milliseconds) [info] - must respect buffer size (666 milliseconds) [WARN] [08/03/2025 18:59:17.276] [HubSpec-pekko.actor.default-dispatcher-6] [pekko://HubSpec/user/StreamSupervisor*] received dead letter from Actor[pekko://HubSpec/system/testProbe-24#1843412432]: GetChildren --- Stream actors debug dump --- Stream is completed. No debug information is available [info] - must work with long streams *** FAILED *** (5 seconds, 43 milliseconds) [info] A timeout occurred waiting for a future to complete. Waited 3000000000 nanoseconds. (HubSpec.scala:150) [info] org.scalatest.concurrent.ScalaFutures$$anon$1$$anon$2: [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:339) [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue(Futures.scala:476) [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue$(Futures.scala:475) [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValue(ScalaFutures.scala:281) [info] at org.apache.pekko.stream.scaladsl.HubSpec.$anonfun$new$12(HubSpec.scala:150) [info] at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85) [info] at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83) [info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) [info] at org.scalatest.Transformer.apply(Transformer.scala:22) [info] at org.scalatest.Transformer.apply(Transformer.scala:20) [info] at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240) [info] at org.scalatest.TestSuite.withFixture(TestSuite.scala:196) [info] at org.scalatest.TestSuite.withFixture$(TestSuite.scala:195) [info] at org.apache.pekko.stream.testkit.StreamSpec.withFixture(StreamSpec.scala:50) [info] at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1238) [info] at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTest$1(AnyWordSpecLike.scala:1250) [info] at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306) [info] at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1250) [info] at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:1232) [info] at org.apache.pekko.testkit.PekkoSpec.runTest(PekkoSpec.scala:79) [info] at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$runTests$1(AnyWordSpecLike.scala:1309) [info] at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:413) [info] at scala.collection.immutable.List.foreach(List.scala:334) [info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) [info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390) [info] at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:427) [info] at scala.collection.immutable.List.foreach(List.scala:334) [info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) [info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396) [info] at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475) [info] at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1309) [info] at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:1308) [info] at org.apache.pekko.testkit.PekkoSpec.runTests(PekkoSpec.scala:79) [info] at org.scalatest.Suite.run(Suite.scala:1114) [info] at org.scalatest.Suite.run$(Suite.scala:1096) [info] at org.apache.pekko.testkit.PekkoSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(PekkoSpec.scala:79) [info] at org.scalatest.wordspec.AnyWordSpecLike.$anonfun$run$1(AnyWordSpecLike.scala:1354) [info] at org.scalatest.SuperEngine.runImpl(Engine.scala:535) [info] at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1354) [info] at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:1352) [info] at org.apache.pekko.testkit.PekkoSpec.org$scalatest$BeforeAndAfterAll$$super$run(PekkoSpec.scala:79) [info] at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213) [info] at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210) [info] at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208) [info] at org.apache.pekko.testkit.PekkoSpec.run(PekkoSpec.scala:79) [info] at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321) [info] at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517) [info] at sbt.ForkMain$Run.lambda$runTest$1(ForkMain.java:414) [info] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328) [info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1095) [info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:619) [info] at java.base/java.lang.Thread.run(Thread.java:1447) ``` Some tests in HubSpec pass but a few related to long streams fail and they all seem to stem from a message ending up on the dead letter queue instead of being passed successfully. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For additional commands, e-mail: notifications-h...@pekko.apache.org
