The GitHub Actions job "Pull Requests" on pekko.git/optimize-stream-boundary-batching has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run: 1f030f12e454a6d422560cb8c55d108ccdd684ec / 虎鸣 <[email protected]> perf: batch async boundary elements Motivation: Async stream islands send each element across the internal actor boundary as a separate boundary event, which adds per-element allocation and mailbox traffic. Modification: Batch elements produced during an interpreter run for internal stream boundaries and flush them when the interpreter parks. Let the input boundary implement the internal BoundarySubscriber directly, cap output batch size at 1024 elements, flush pending batch elements before completion or upstream failure, and keep cancellation and already-terminated paths clearing pending elements. Store initialized boundary lists in arrays, add a fused baseline to the async-boundary benchmark, and add regression coverage for boundary ordering, terminal ordering, demand, cancellation, supervision, and failure draining. Result: Internal async boundary crossings allocate fewer boundary events and actor messages while preserving element order, demand bounds, terminal ordering, and supervision behavior. Tests: - rtk scalafmt --mode diff-ref=origin/main -- passed - rtk scalafmt --list --mode diff-ref=origin/main -- passed - rtk git diff --check -- passed - rtk sbt "stream-tests / Test / testOnly org.apache.pekko.stream.FusingSpec -- -z \"drain asynchronous boundary batches before failing\"" -- passed, 1 test - rtk sbt "stream-tests / Test / testOnly org.apache.pekko.stream.FusingSpec org.apache.pekko.stream.scaladsl.PublisherSinkSpec org.apache.pekko.stream.io.FileSinkSpec org.apache.pekko.stream.scaladsl.FlowMapWithResourceSpec" "stream / mimaReportBinaryIssues" -- passed, 53 tests and MiMa - rtk bash -lc 'set -o pipefail; sbt "bench-jmh/Jmh/run -wi 1 -i 3 -w 5s -r 5s -f 1 -prof gc .*AsyncBoundaryThroughputBenchmark.*" 2>&1 | tee /tmp/pekko-async-boundary-final-squashed.log' -- passed - rtk qodercli --help -- passed, confirmed -p/--print, --output-format, --cwd, and --attachment - qodercli stdout review of /tmp/project-review.diff -- passed, no must-fix findings - Independent subAgent review of /tmp/project-review.diff -- passed, no must-fix findings References: None - internal stream boundary throughput optimization Report URL: https://github.com/apache/pekko/actions/runs/28717441794 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
