You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@pekko.apache.org by "He-Pin (via GitHub)" <gi...@apache.org> on 2026/04/24 17:47:06 UTC
[I] failed: FlowMapAsyncPartitionedSpec.scala:393 [pekko]
He-Pin opened a new issue, #2903:
URL: https://github.com/apache/pekko/issues/2903
Failed(org.scalatest.concurrent.ScalaFutures$$anon$2: A timeout occurred waiting for a future to complete. Waited 60000000000 nanoseconds.)]
[04-24 12:49:57.728] [info] - must resume after multiple failures if resume supervision is in place *** FAILED *** (1 minute)
[04-24 12:49:57.728] [info] A timeout occurred waiting for a future to complete. Waited 60000000000 nanoseconds. (FlowMapAsyncPartitionedSpec.scala:393)
[04-24 12:49:57.728] [info] org.scalatest.concurrent.ScalaFutures$$anon$2:
[04-24 12:49:57.728] [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:345)
[04-24 12:49:57.728] [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue(Futures.scala:476)
[04-24 12:49:57.728] [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue$(Futures.scala:259)
[04-24 12:49:57.729] [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValue(ScalaFutures.scala:281)
[04-24 12:49:57.729] [info] at org.apache.pekko.stream.scaladsl.FlowMapAsyncPartitionedSpec.f$proxy14$1(FlowMapAsyncPartitionedSpec.scala:393)
[04-24 12:49:57.729] [info] at org.apache.pekko.stream.scaladsl.FlowMapAsyncPartitionedSpec.$init$$$anonfun$1$$anonfun$13(FlowMapAsyncPartitionedSpec.scala:383)
[04-24 12:49:57.729] [info] at org.scalatest.Transformer.apply$$anonfun$1(Transformer.scala:22)
[04-24 12:49:57.729] [info] at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
[04-24 12:49:57.729] [info] at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:31)
[04-24 12:49:57.729] [info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[04-24 12:49:57.729] [info] at org.scalatest.Transformer.apply(Transformer.scala:22)
[04-24 12:49:57.729] [info] at org.scalatest.Transformer.apply(Transformer.scala:21)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1118)
[04-24 12:49:57.729] [info] at org.apache.pekko.testkit.WithLogCapturing.$anonfun$1(WithLogCapturing.scala:46)
[04-24 12:49:57.729] [info] at org.apache.pekko.testkit.EventFilter.intercept(TestEventListener.scala:128)
[04-24 12:49:57.729] [info] at org.apache.pekko.testkit.WithLogCapturing.withFixture(WithLogCapturing.scala:49)
[04-24 12:49:57.729] [info] at org.apache.pekko.testkit.WithLogCapturing.withFixture$(WithLogCapturing.scala:28)
[04-24 12:49:57.729] [info] at org.apache.pekko.stream.scaladsl.FlowMapAsyncPartitionedSpec.withFixture(FlowMapAsyncPartitionedSpec.scala:45)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike.invokeWithFixture$1(AnyWordSpecLike.scala:1124)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTest$$anonfun$1(AnyWordSpecLike.scala:1128)
[04-24 12:49:57.729] [info] at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTest(AnyWordSpecLike.scala:1128)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTest$(AnyWordSpecLike.scala:44)
[04-24 12:49:57.729] [info] at org.apache.pekko.testkit.PekkoSpec.runTest(PekkoSpec.scala:82)
[04-24 12:49:57.729] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTests$$anonfun$1(AnyWordSpecLike.scala:1187)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.traverseSubNodes$1$$anonfun$1(Engine.scala:413)
[04-24 12:49:57.730] [info] at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
[04-24 12:49:57.730] [info] at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
[04-24 12:49:57.730] [info] at scala.collection.immutable.List.foreach(List.scala:334)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:429)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:390)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.traverseSubNodes$1$$anonfun$1(Engine.scala:427)
[04-24 12:49:57.730] [info] at scala.runtime.function.JProcedure1.apply(JProcedure1.java:15)
[04-24 12:49:57.730] [info] at scala.runtime.function.JProcedure1.apply(JProcedure1.java:10)
[04-24 12:49:57.730] [info] at scala.collection.immutable.List.foreach(List.scala:334)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:429)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:396)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:475)
[04-24 12:49:57.730] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTests(AnyWordSpecLike.scala:1187)
[04-24 12:49:57.730] [info] at org.scalatest.wordspec.AnyWordSpecLike.runTests$(AnyWordSpecLike.scala:44)
[04-24 12:49:57.730] [info] at org.apache.pekko.testkit.PekkoSpec.runTests(PekkoSpec.scala:82)
[04-24 12:49:57.730] [info] at org.scalatest.Suite.run(Suite.scala:1114)
[04-24 12:49:57.730] [info] at org.scalatest.Suite.run$(Suite.scala:564)
[04-24 12:49:57.730] [info] at org.apache.pekko.testkit.PekkoSpec.org$scalatest$wordspec$AnyWordSpecLike$$super$run(PekkoSpec.scala:82)
[04-24 12:49:57.730] [info] at org.scalatest.wordspec.AnyWordSpecLike.run$$anonfun$1(AnyWordSpecLike.scala:1232)
[04-24 12:49:57.730] [info] at org.scalatest.SuperEngine.runImpl(Engine.scala:535)
[04-24 12:49:57.730] [info] at org.scalatest.wordspec.AnyWordSpecLike.run(AnyWordSpecLike.scala:1232)
[04-24 12:49:57.730] [info] at org.scalatest.wordspec.AnyWordSpecLike.run$(AnyWordSpecLike.scala:44)
[04-24 12:49:57.730] [info] at org.apache.pekko.testkit.PekkoSpec.org$scalatest$BeforeAndAfterAll$$super$run(PekkoSpec.scala:82)
[04-24 12:49:57.731] [info] at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)
[04-24 12:49:57.731] [info] at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:217)
[04-24 12:49:57.731] [info] at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:135)
[04-24 12:49:57.731] [info] at org.apache.pekko.testkit.PekkoSpec.run(PekkoSpec.scala:82)
[04-24 12:49:57.731] [info] at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:321)
[04-24 12:49:57.731] [info] at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:517)
[04-24 12:49:57.731] [info] at sbt.ForkMain$Run.lambda$runTest$1(ForkMain.java:414)
[04-24 12:49:57.731] [info] at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
[04-24 12:49:57.731] [info] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[04-24 12:49:57.731] [info] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[04-24 12:49:57.731] [info] at java.base/java.lang.Thread.run(Thread.java:840)
--
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-unsubscribe@pekko.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [I] failed: FlowMapAsyncPartitionedSpec.scala:393 [pekko]
Posted by "He-Pin (via GitHub)" <gi...@apache.org>.
He-Pin commented on issue #2903:
URL: https://github.com/apache/pekko/issues/2903#issuecomment-4576180485
Root cause found and fixed in #3009: `MapAsyncPartitioned.pushNextIfPossibleOrdered`'s non-empty-partitions branch ended with only `drainQueue()` and never called `pullIfNeeded()` — the only `completeStage()` check on the push path. When the final buffered elements are resumed failures (the `while` loop's `Failure`/`Supervision.Resume` arm dequeues without a completion check), the buffer empties after upstream finish but the stage never completes, causing the 60s timeout. This is the residual completion-path sibling of the #2899 `drainQueue` race. Fixed by mirroring the unordered branch's trailing `pullIfNeeded()`, plus an unordered regression test.
--
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-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [I] failed: FlowMapAsyncPartitionedSpec.scala:393 [pekko]
Posted by "He-Pin (via GitHub)" <gi...@apache.org>.
He-Pin commented on issue #2903:
URL: https://github.com/apache/pekko/issues/2903#issuecomment-4575459332
I'm working on this.
--
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-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [I] failed: FlowMapAsyncPartitionedSpec.scala:393 [pekko]
Posted by "pjfanning (via GitHub)" <gi...@apache.org>.
pjfanning commented on issue #2903:
URL: https://github.com/apache/pekko/issues/2903#issuecomment-4575268457
happened today even after the getVolatile changes
```
--> [A Flow with mapAsyncPartitioned must resume after multiple failures if resume supervision is in place] Start of log messages of test that [Failed(org.scalatest.concurrent.ScalaFutures$$anon$1$$anon$2: A timeout occurred waiting for a future to complete. Waited 60000000000 nanoseconds.)]
<-- [A Flow with mapAsyncPartitioned must resume after multiple failures if resume supervision is in place] End of log messages of test that [Failed(org.scalatest.concurrent.ScalaFutures$$anon$1$$anon$2: A timeout occurred waiting for a future to complete. Waited 60000000000 nanoseconds.)]
[05-29 12:22:09.512] [info] - must resume after multiple failures if resume supervision is in place *** FAILED *** (1 minute)
[05-29 12:22:09.512] [info] A timeout occurred waiting for a future to complete. Waited 60000000000 nanoseconds. (FlowMapAsyncPartitionedSpec.scala:398)
[05-29 12:22:09.512] [info] org.scalatest.concurrent.ScalaFutures$$anon$1$$anon$2:
[05-29 12:22:09.512] [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:339)
[05-29 12:22:09.513] [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue(Futures.scala:476)
[05-29 12:22:09.513] [info] at org.scalatest.concurrent.Futures$FutureConcept.futureValue$(Futures.scala:475)
[05-29 12:22:09.513] [info] at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValue(ScalaFutures.scala:281)
[05-29 12:22:09.543] [info] at org.apache.pekko.stream.scaladsl.FlowMapAsyncPartitionedSpec.$anonfun$new$59(FlowMapAsyncPartitionedSpec.scala:398)
[05-29 12:22:09.544] [info] at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)
[05-29 12:22:09.544] [info] at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)
[05-29 12:22:09.545] [info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[05-29 12:22:09.545] [info] at org.scalatest.Transformer.apply(Transformer.scala:22)
[05-29 12:22:09.545] [info] at org.scalatest.Transformer.apply(Transformer.scala:20)
[05-29 12:22:09.545] [info] at org.scalatest.wordspec.AnyWordSpecLike$$anon$3.apply(AnyWordSpecLike.scala:1240)
[05-29 12:22:09.545] [info] at org.apache.pekko.testkit.WithLogCapturing.$anonfun$withFixture$1(WithLogCapturing.scala:46)
[05-29 12:22:09.547] [info] at org.apache.pekko.testkit.EventFilter.intercept(TestEventListener.scala:128)
[05-29 12:22:09.547] [info] at org.apache.pekko.testkit.WithLogCapturing.withFixture(WithLogCapturing.scala:44)
[05-29 12:22:09.547] [info] at org.apache.pekko.testkit.WithLogCapturing.withFixture$(WithLogCapturing.scala:31)
[05-29 12:22:09.547] [info] at
```
--
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-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org
Re: [I] failed: FlowMapAsyncPartitionedSpec.scala:393 [pekko]
Posted by "He-Pin (via GitHub)" <gi...@apache.org>.
He-Pin closed issue #2903: failed: FlowMapAsyncPartitionedSpec.scala:393
URL: https://github.com/apache/pekko/issues/2903
--
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-unsubscribe@pekko.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org