Release Notes (1.1.x)

Apache Pekko 1.1.x releases support Java 8 and above.

1.1.1

Pekko 1.1.1 is a bugfix release.

Bug Fixes

  • Cluster sharding delivers message to the wrong entity (PR1464)

1.1.0

Release notes for Apache Pekko 1.1.0. See GitHub Milestone for 1.1.0-M1 and GitHub Milestone for 1.1.0 for a fuller list of changes.

Pekko Remote and/or Cluster users who use Netty instead of Aeron should note that we now support Netty 4 instead of Netty 3. It is recommended that you run some tests before you go into production with this new release.

Please review the Known Issues below.

1.0.x changes

Apache Pekko 1.1.0 contains all of the changes that have been released in the 1.0.x releases up to and including v1.0.3.

Bug Fixes

  • in TlsActor, flush data to user only after handshake has finished (PR1128)
  • proper path when promise actor terminated quickly (PR1156)
  • TcpDnsClient cannot recover if registration on TcpConnection times out (PR1183)
  • Fix uncaught decider exception in Split with Supervision.resumingDecider (PR1207)
  • Pull instead of throw exception in groupBy operator (PR1210)
  • Fix ByteIterator indexWhere method (PR1282)
  • Assertion failure caused by exception during pre-start (#1384) (not in v1.1.0-M1)

Additional APIs

  • Add create method to PFBuilder (PR947)
  • Add asInputStream to ByteString (PR1085)
  • Add additional mailbox selector for typed props (PR1096) (not in v1.1.0-M1)
  • Add missing create method to javadsl Graph (PR1230)
  • Add new indexOf functions to ByteString for byte lookups (PR1247)
  • Add UntypedAbstractActorWithTimers (#1360) (not in v1.1.0-M1)
  • Add isCompleted method to BoundedSourceQueue (PR1374) (not in v1.1.0-M1)
  • Add Behaviors.receiveMessageWithSame (#1444) (not in v1.1.0-M1)

The Stream API has been updated to add some extra functions.

  • add collectFirst stream operator (PR984)
  • add collectWhile stream operator (PR964)
  • add dimap stream operator (PR942)
  • add flatten stream operator (PR937)
  • add flattenMerge stream operator (PR1045)
  • add foldWhile stream operator (PR1012)
  • add mapAsyncPartitioned / mapAsyncPartitionedUnordered stream operators (PR561, PR676)
  • add mapWithResource stream operator (PR931, PR1053)
  • add onErrorComplete stream operator (PR913)
  • add support for for comprehensions (PR935)
  • add Sink.exists operator (PR990)
  • add Sink.forall operator (PR989)
  • add Source.iterate operator (PR1244)
  • added extra retry operators that allow users to provide a predicate to decide whether to retry based on the exception (PR1269)
  • add QueueOfferResult.closed() method for Java DSL users (PR1377) (not in v1.1.0-M1)
  • add optionalVia/unsafeOptionalDataVia operators (PR1422) (not in v1.1.0-M1)
  • add alsoTo/alsoToContext operators to SourceWithContext/FlowWithContext (PR1443) (not in v1.1.0-M1)
  • add wireTap/wireTapContext operators to SourceWithContext/FlowWithContext (PR1446) (not in v1.1.0-M1)

The Stream Testkit Java DSL has some extra functions.

  • Add more Java DSL functions to StreamTestKit to better match the Scala DSL (PR1186)
  • Add expectNextN to StreamTestKit for javadsl (PR962)

Removed

  • The pekko-protobuf jar is no longer published. The pekko-protobuf-v3 jar is still published (PR489)

Other Changes

  • Scala 2 inline optimizer has been enabled
  • Support fork-join-executor.maximum-pool-size config (PR485)
  • Classic Remoting was updated to use Netty 4 instead of Netty 3 (PR643)
  • Replace SubstreamCancelStrategy with SupervisionDecider for Split (PR252)
  • Support Jackson StreamReadConstraints and StreamWriteConstraints (PR564)
  • Support configuration for Jackson Recycler Pool (PR1192)
  • pekko-multi-node-testkit was changed to use Netty 4 instead of Netty 3 (PR539)
  • add junit5 support to pekko-testkit-typed (PR751)
  • Fix maybe throw for MinimalStage (Stream Unfold). (PR822)
  • Add dedicated stream timeout exceptions for timeout related operators (PR861)
  • Reimplement MapConcat operator without statefulMapConcat (PR902)
  • Make SingleConsumerMultiProducer the default mailbox for stream (PR917)
  • Rework PhiAccrualFailureDetector to enable monitoring of interval (PR1137)
  • Remove the deprecation of statefulMapConcat operator (PR1147)
  • Add AbruptStreamTerminationException as super class of some related exceptions (PR1201)
  • For Pekko Persistence DurableState API, a new DeleteRevisionException has been added and the aim is to have implementations fail with that exception if a deleteObject does not delete exactly one record for that revision (PR1271)
  • Support for a dispatcher that uses Virtual Threads (PR1299) (not in v1.1.0-M1)
  • Avoid unnecessary shard updates while shutting down (PR1342) (not in v1.1.0-M1)
  • Support just warning instead of error when pekko.scheduler.tick-duration < 10ms on Windows (#1364) (not in v1.1.0-M1)
  • Support the flattening syntax for supervising (PR1386) (not in v1.1.0-M1)
  • Fix uncurried Pekko Stream ops in javadsl (PR1406) (not in v1.1.0-M1)
  • A new config has been added to support users of Pekko Persistence snapshots to choose not to modify the persisted data to include Pekko serializer names (PR1423) (not in v1.1.0-M1)
  • Some performance changes in the Stream code (PR48, PR49, PR278, PR363, PR408, PR872, PR923, PR983, PR1001, PR1027, PR1249, PR1250)

Dependency Changes

Most of the dependency changes are small patch level upgrades. Some exceptions include:

  • The protobuf-java code that is shaded and released as pekko-protobuf-v3 has been upgraded to protobuf-java 3.25.3
  • slf4j was updated to v2 (PR748)
  • upgrade from netty 3 to netty 4 (pekko-remote and pekko-multi-node-testkit)
  • Jackson 2.17.2
  • Aeron 1.45.0 and Agrona 1.22.0 (newer versions of these libs require Java 17)

Known Issues

  • A race condition has been introduced into pekko-cluster-sharding which needs to be fixed in a Pekko 1.1.1 release. Users who use Cluster Sharding should skip this release. The problem does not appear in v1.1.0-M1. (#1463)
  • For Scala 2.12 users, we have run into an issue with stream-testkit function expectNextWithTimeoutPF (#1393).
    • For now, the consensus is not to change this as it appears to be more of a Scala 2.12 compiler issue.
    • Affected Scala 2.12 users can stick with Pekko 1.0 or change their code to get it to compile. The most reliable code change is to move the PartialFunction code and declare it as a val.
    • If you feel strongly that Apache Pekko should try to fix this, please get in touch.
1.1.1