Build Logs

1##################################

2Clonning https://github.com/apache/pekko-projection.git into /build/repo using revision v1.1.0

3##################################

4Note: switching to 'be34eadcb1771e45abf7207bddaeb22633b7d4f8'.

6You are in 'detached HEAD' state. You can look around, make experimental

7changes and commit them, and you can discard any commits you make in this

8state without impacting any branches by switching back to a branch.

10If you want to create a new branch to retain commits you create, you may

11do so (now or later) by using -c with the switch command. Example:

13 git switch -c <new-branch-name>

15Or undo this operation with:

17 git switch -

19Turn off this advice by setting config variable advice.detachedHead to false

21Would override fixed Scala version: 3.3.5

22----

23Preparing build for 3.8.0-RC4

24Scala binary version found: 3.8

25Implicitly using source version 3.8

26Scala binary version found: 3.8

27Implicitly using source version 3.8

28Would try to apply common scalacOption (best-effort, sbt/mill only):

29Append: ,REQUIRE:-source:3.8

30Remove: ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

32Try apply source patch:

33Path: project/Dependencies.scala

34Pattern: val Scala3 = "3.3.5"

35Replacement: val Scala3 = "3.8.0-RC4"

36Starting compilation server

37Compiling project (Scala 3.7.3, JVM (17))

38Compiled project (Scala 3.7.3, JVM (17))

39Successfully applied pattern 'val Scala3 = "3.3.5"' in project/Dependencies.scala

40----

41Starting build for 3.8.0-RC4

42Execute tests: true

43sbt project found:

44Sbt version 1.10.7 is not supported, minimal supported version is 1.11.5

45Enforcing usage of sbt in version 1.11.5

46No prepare script found for project apache/pekko-projection

47##################################

48Scala version: 3.8.0-RC4

49Targets: org.apache.pekko%pekko-projection-bom org.apache.pekko%pekko-projection-cassandra org.apache.pekko%pekko-projection-core org.apache.pekko%pekko-projection-durable-state org.apache.pekko%pekko-projection-eventsourced org.apache.pekko%pekko-projection-jdbc org.apache.pekko%pekko-projection-kafka org.apache.pekko%pekko-projection-slick org.apache.pekko%pekko-projection-testkit

50Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.5\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}

51##################################

52Using extra scalacOptions: ,REQUIRE:-source:3.8

53Filtering out scalacOptions: ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

54[sbt_options] declare -a sbt_options=()

55[process_args] java_version = '17'

56[copyRt] java9_rt = '/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8/rt.jar'

57# Executing command line:

58java

59-Dfile.encoding=UTF-8

60-Dcommunitybuild.scala=3.8.0-RC4

61-Dcommunitybuild.project.dependencies.add=

62-Xmx7G

63-Xms4G

64-Xss8M

65-Dsbt.script=/root/.sdkman/candidates/sbt/current/bin/sbt

66-Dscala.ext.dirs=/root/.sbt/1.0/java9-rt-ext-eclipse_adoptium_17_0_8

67-jar

68/root/.sdkman/candidates/sbt/1.11.5/bin/sbt-launch.jar

69"setCrossScalaVersions 3.8.0-RC4"

70"++3.8.0-RC4 -v"

71"mapScalacOptions ",REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s" ",-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e""

72"set every credentials := Nil"

73"excludeLibraryDependency com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}"

74"removeScalacOptionsStartingWith -P:wartremover"

76moduleMappings

77"runBuild 3.8.0-RC4 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.5\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}""" org.apache.pekko%pekko-projection-bom org.apache.pekko%pekko-projection-cassandra org.apache.pekko%pekko-projection-core org.apache.pekko%pekko-projection-durable-state org.apache.pekko%pekko-projection-eventsourced org.apache.pekko%pekko-projection-jdbc org.apache.pekko%pekko-projection-kafka org.apache.pekko%pekko-projection-slick org.apache.pekko%pekko-projection-testkit"

79[info] welcome to sbt 1.11.5 (Eclipse Adoptium Java 17.0.8)

80[info] loading settings for project repo-build from akka.sbt, plugins.sbt...

81[info] loading project definition from /build/repo/project

82[info] compiling 14 Scala sources to /build/repo/project/target/scala-2.12/sbt-1.0/classes ...

83[info] Non-compiled module 'compiler-bridge_2.12' for Scala 2.12.20. Compiling...

84[info] Compilation completed in 8.714s.

98[info] done compiling

100 .configs(IntegrationTest)

101 ^

103 .settings(headerSettings(IntegrationTest))

104 ^

106 .settings(Defaults.itSettings)

107 ^

109 .configs(IntegrationTest)

110 ^

112 .settings(headerSettings(IntegrationTest))

113 ^

115 .settings(Defaults.itSettings)

116 ^

118 .configs(IntegrationTest)

119 ^

121 .settings(headerSettings(IntegrationTest))

122 ^

124 .settings(Defaults.itSettings)

125 ^

127 .settings(headerSettings(IntegrationTest))

128 ^

130 .settings(Defaults.itSettings)

131 ^

133 .configs(IntegrationTest.extend(Test))

134 ^

136 .settings(headerSettings(IntegrationTest))

137 ^

139 .settings(Defaults.itSettings)

140 ^

142 .configs(IntegrationTest)

143 ^

145 .settings(headerSettings(IntegrationTest))

146 ^

148 .settings(Defaults.itSettings)

149 ^

151 .configs(IntegrationTest)

152 ^

154 .settings(headerSettings(IntegrationTest))

155 ^

157 .settings(Defaults.itSettings)

158 ^

160 .configs(IntegrationTest)

161 ^

163 .configs(IntegrationTest.extend(Test))

164 ^

166 .settings(headerSettings(IntegrationTest))

167 ^

169 .settings(Defaults.itSettings)

170 ^

171[info] loading settings for project projection from build.sbt...

172[info] resolving key references (20178 settings) ...

173[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

174[info] set current project to pekko-projection-root (in build file:/build/repo/)

194Execute setCrossScalaVersions: 3.8.0-RC4

195[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

196OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in cassandra/crossScalaVersions

197OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in core-test/crossScalaVersions

198OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in slick/crossScalaVersions

199OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in core/crossScalaVersions

200OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in projection/crossScalaVersions

201OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in durable-state/crossScalaVersions

202OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in eventsourced/crossScalaVersions

203OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in kafka-test/crossScalaVersions

204OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in docs/crossScalaVersions

205OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in jdbc/crossScalaVersions

206OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in examples/crossScalaVersions

207OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in bill-of-materials/crossScalaVersions

208OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in testkit/crossScalaVersions

209OpenCB::Changing crossVersion 3.8.0-RC4 -> 3.8.0-RC4 in kafka/crossScalaVersions

210[info] set current project to pekko-projection-root (in build file:/build/repo/)

211[info] Setting Scala version to 3.8.0-RC4 on 14 projects.

212[info] Switching Scala version on:

213[info] examples (2.13.16, 2.12.20, 3.8.0-RC4)

214[info] * projection (2.13.16, 2.12.20, 3.8.0-RC4)

215[info] slick (2.13.16, 2.12.20, 3.8.0-RC4)

216[info] jdbc (2.13.16, 2.12.20, 3.8.0-RC4)

217[info] docs (2.13.16, 2.12.20, 3.8.0-RC4)

218[info] core-test (2.13.16, 2.12.20, 3.8.0-RC4)

219[info] cassandra (2.13.16, 2.12.20, 3.8.0-RC4)

220[info] eventsourced (2.13.16, 2.12.20, 3.8.0-RC4)

221[info] kafka (2.13.16, 2.12.20, 3.8.0-RC4)

222[info] durable-state (2.13.16, 2.12.20, 3.8.0-RC4)

223[info] core (2.13.16, 2.12.20, 3.8.0-RC4)

224[info] kafka-test (2.13.16, 2.12.20, 3.8.0-RC4)

225[info] bill-of-materials (2.13.16, 2.12.20, 3.8.0-RC4)

226[info] testkit (2.13.16, 2.12.20, 3.8.0-RC4)

227[info] Excluding projects:

228[info] Reapplying settings...

229[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

230[info] set current project to pekko-projection-root (in build file:/build/repo/)

231Execute mapScalacOptions: ,REQUIRE:-source:3.8,-Wconf:msg=can be rewritten automatically under:s ,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

232[info] Reapplying settings...

233[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

234[info] set current project to pekko-projection-root (in build file:/build/repo/)

235[info] Defining Global / credentials, ThisBuild / credentials and 13 others.

236[info] The new values will be used by Compile / scalafmtOnly, Global / pgpSelectPassphrase and 112 others.

237[info] Run `last` for details.

238[info] Reapplying settings...

239[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

240[info] set current project to pekko-projection-root (in build file:/build/repo/)

241Execute excludeLibraryDependency: com.github.ghik:zerowaste_{scalaVersion} com.olegpy:better-monadic-for_3 org.polyvariant:better-tostring_{scalaVersion} org.wartremover:wartremover_{scalaVersion}

242[info] Reapplying settings...

243OpenCB::Failed to reapply settings in excludeLibraryDependency: Reference to undefined setting:

245 Global / allExcludeDependencies from Global / allExcludeDependencies (CommunityBuildPlugin.scala:331)

246 Did you mean durable-state / allExcludeDependencies ?

247 , retry without global scopes

248[info] Reapplying settings...

249[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

250[info] set current project to pekko-projection-root (in build file:/build/repo/)

251Execute removeScalacOptionsStartingWith: -P:wartremover

252[info] Reapplying settings...

253[info] Scala 2 optimizer/inliner enabled, to disable set the pekko.no.inline system property

254[info] set current project to pekko-projection-root (in build file:/build/repo/)

255[success] Total time: 0 s, completed Dec 22, 2025, 6:27:10 PM

256Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":[],"sourcePatches":[{"path":"project/Dependencies.scala","pattern":"val Scala3 = \"3.3.5\"","replaceWith":"val Scala3 = \"<SCALA_VERSION>\""}]}

257Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),Full,List()))

258Starting build...

259Projects: Set(slick, jdbc, core-test, cassandra, eventsourced, kafka, durable-state, core, bill-of-materials, testkit)

260Starting build for ProjectRef(file:/build/repo/,jdbc) (pekko-projection-jdbc)... [0/10]

261OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.8` in Scala 2.12.20 module Global

262OpenCB::Filter out '-Xfatal-warnings', matches setting pattern '^-?-Xfatal-warnings'

263Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

264[info] compiling 34 Scala sources and 1 Java source to /build/repo/core/target/scala-3.8.0-RC4/classes ...

265[info] done compiling

266[info] compiling 12 Scala sources to /build/repo/jdbc/target/scala-3.8.0-RC4/classes ...

267[info] done compiling

268[info] compiling 13 Scala sources to /build/repo/testkit/target/scala-3.8.0-RC4/classes ...

269[info] done compiling

270[info] compiling 16 Scala sources and 1 Java source to /build/repo/core-test/target/scala-3.8.0-RC4/test-classes ...

271[info] done compiling

272[info] compiling 2 Scala sources and 1 Java source to /build/repo/jdbc/target/scala-3.8.0-RC4/test-classes ...

273[info] done compiling

274SLF4J(W): A number (1) of logging calls during the initialization phase have been intercepted and are

275SLF4J(W): now being replayed. These are subject to the filtering rules of the underlying logging system.

276SLF4J(W): See also https://www.slf4j.org/codes.html#replay

277[info] JdbcProjectionTest:

278# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@4262883c

279[info] - atLeastOnceFlowShouldStoreOffset

280# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@6baffe66

281[info] - atLeastOnceShouldStoreOffset

282# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@7afa5aa2

283[info] - exactlyOnceShouldStoreOffset

284[info] - exactlyOnceShouldRestartFromPreviousOffset

285# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@490e8d1f

286[info] - atLeastOnceShouldRestartFromPreviousOffset

287# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@1438c6e4

288[info] - groupedShouldStoreOffset

289[info] JdbcSettingsSpec:

290[info] Loading JdbcSettings

291[info] - must accept convert a valid string to integer when reading the pool size (125 milliseconds)

292[info] - must accept convert a valid string (with spaces) to integer when reading the pool size (50 milliseconds)

293[info] - must accept a correctly filled pool size (43 milliseconds)

298[info] - must dont' fail if user decide to step out of a thread-pool-executor (37 milliseconds)

299[info] H2JdbcOffsetStoreSpec:

300[info] The JdbcOffsetStore

301[info] - must not fail when dropIfExists and createIfNotExists are called [H2 Database] (120 milliseconds)

302[info] - must create and update offsets [H2 Database] (54 milliseconds)

303[info] - must save and retrieve offsets of type Long [H2 Database] (8 milliseconds)

304[info] - must save and retrieve offsets of type java.lang.Long [H2 Database] (4 milliseconds)

305[info] - must save and retrieve offsets of type Int [H2 Database] (10 milliseconds)

306[info] - must save and retrieve offsets of type java.lang.Integer [H2 Database] (8 milliseconds)

307[info] - must save and retrieve offsets of type String [H2 Database] (5 milliseconds)

308[info] - must save and retrieve offsets of type pekko.persistence.query.Sequence [H2 Database] (9 milliseconds)

309[info] - must save and retrieve offsets of type pekko.persistence.query.TimeBasedUUID [H2 Database] (8 milliseconds)

310[info] - must save and retrieve MergeableOffset [H2 Database] (12 milliseconds)

311[info] - must add new offsets to MergeableOffset [H2 Database] (14 milliseconds)

312[info] - must update timestamp [H2 Database] (10 milliseconds)

313[info] - must clear offset [H2 Database] (11 milliseconds)

314[info] - must read and save paused [H2 Database] (13 milliseconds)

315Starting build for ProjectRef(file:/build/repo/,eventsourced) (pekko-projection-eventsourced)... [1/10]

316Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

317[info] compiling 3 Scala sources to /build/repo/eventsourced/target/scala-3.8.0-RC4/classes ...

318[info] done compiling

319[info] compiling 1 Scala source to /build/repo/eventsourced/target/scala-3.8.0-RC4/test-classes ...

320[info] done compiling

321SLF4J(W): A number (4) of logging calls during the initialization phase have been intercepted and are

322SLF4J(W): now being replayed. These are subject to the filtering rules of the underlying logging system.

323SLF4J(W): See also https://www.slf4j.org/codes.html#replay

324[info] EventSourcedProviderSpec:

325[info] Should provide different events

326[info] by tags

327[info] - for different tags (414 milliseconds)

328[info] - for different journals (247 milliseconds)

329[info] by slices

330[info] - for different slices (356 milliseconds)

331[info] - for different journals (242 milliseconds)

332Starting build for ProjectRef(file:/build/repo/,bill-of-materials) (pekko-projection-bom)... [2/10]

333Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

334Starting build for ProjectRef(file:/build/repo/,cassandra) (pekko-projection-cassandra)... [3/10]

335Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

336[info] compiling 5 Scala sources to /build/repo/cassandra/target/scala-3.8.0-RC4/classes ...

337[info] done compiling

338Starting build for ProjectRef(file:/build/repo/,core) (pekko-projection-core)... [4/10]

339Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

340Starting build for ProjectRef(file:/build/repo/,testkit) (pekko-projection-testkit)... [5/10]

341Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

342[info] compiling 2 Scala sources and 1 Java source to /build/repo/testkit/target/scala-3.8.0-RC4/test-classes ...

343[info] done compiling

344SLF4J(W): A number (1) of logging calls during the initialization phase have been intercepted and are

345SLF4J(W): now being replayed. These are subject to the filtering rules of the underlying logging system.

346SLF4J(W): See also https://www.slf4j.org/codes.html#replay

347[info] ProjectionTestKitTest:

348[info] TestProjectionSpec:

349[info] TestProjection

350[info] - must run an ActorHandler (188 milliseconds)

351[info] - failureInsideStreamPropagatesToTestkit

352[info] ProjectionTestKitSpec:

353[info] ProjectionTestKit

354[info] - must assert progress of a projection (181 milliseconds)

355[info] - must retry assertion function until it succeeds within a max timeout (1 second, 310 milliseconds)

356[info] - must retry assertion function and fail when timeout expires (1 second, 908 milliseconds)

357[info] - failureInsideProjectionPropagatesToTestkit

358[info] - assertProgressOfAProjection

359[info] - must failure inside Projection propagates to TestKit (2 seconds, 909 milliseconds)

360[info] - retryAssertionFunctionAndFailWhenTimeoutExpires

361[info] - runAProjectionWithATestSink

362[info] - retryAssertionFunctionUntilItSucceedsWithinAMaxTimeout

363[info] - must failure inside Stream propagates to TestKit (2 seconds, 910 milliseconds)

364[info] - must run a projection with a TestSink (15 milliseconds)

365Starting build for ProjectRef(file:/build/repo/,kafka) (pekko-projection-kafka)... [6/10]

366Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

367[info] compiling 6 Scala sources to /build/repo/kafka/target/scala-3.8.0-RC4/classes ...

368[info] done compiling

369Starting build for ProjectRef(file:/build/repo/,slick) (pekko-projection-slick)... [7/10]

370Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

371[info] compiling 4 Scala sources to /build/repo/slick/target/scala-3.8.0-RC4/classes ...

372[info] done compiling

373[info] compiling 2 Scala sources to /build/repo/slick/target/scala-3.8.0-RC4/test-classes ...

374[info] done compiling

375SLF4J(W): A number (6) of logging calls during the initialization phase have been intercepted and are

376SLF4J(W): now being replayed. These are subject to the filtering rules of the underlying logging system.

377SLF4J(W): See also https://www.slf4j.org/codes.html#replay

378[info] H2SlickOffsetStoreSpec:

379[info] The SlickOffsetStore

380[info] - must not fail when dropIfExists and createIfNotExists are called [H2 Database] (15 milliseconds)

381[info] - must create and update offsets [H2 Database] (142 milliseconds)

382[info] - must save and retrieve offsets of type Long [H2 Database] (12 milliseconds)

383[info] - must save and retrieve offsets of type java.lang.Long [H2 Database] (11 milliseconds)

384[info] - must save and retrieve offsets of type Int [H2 Database] (11 milliseconds)

385[info] - must save and retrieve offsets of type java.lang.Integer [H2 Database] (10 milliseconds)

386[info] - must save and retrieve offsets of type String [H2 Database] (10 milliseconds)

387[info] - must save and retrieve offsets of type org.apache.pekko.persistence.query.Sequence [H2 Database] (12 milliseconds)

388[info] - must save and retrieve offsets of type org.apache.pekko.persistence.query.TimeBasedUUID [H2 Database] (10 milliseconds)

389[info] - must update timestamp [H2 Database] (17 milliseconds)

390[info] - must save and retrieve MergeableOffset [H2 Database] (14 milliseconds)

391[info] - must add new offsets to MergeableOffset [H2 Database] (23 milliseconds)

392[info] - must clear offset [H2 Database] (19 milliseconds)

393[info] - must read and save paused [H2 Database] (20 milliseconds)

394[info] SlickProjectionSpec:

395[info] A Slick exactly-once projection

396[info] - must persist projection and offset in the same write operation (transactional) (429 milliseconds)

397[info] - must skip failing events when using RecoveryStrategy.skip (120 milliseconds)

398[info] - must skip failing events after retrying when using RecoveryStrategy.retryAndSkip (322 milliseconds)

399[info] - must fail after retrying when using RecoveryStrategy.retryAndFail (134 milliseconds)

400[info] - must restart from previous offset - fail with DBIOAction.failed (181 milliseconds)

402[info] - must restart from previous offset - fail with bad insert on user code (149 milliseconds)

403[info] - must verify offsets before and after processing an envelope (55 milliseconds)

404[info] - must skip record if offset verification fails before processing envelope (107 milliseconds)

405[info] - must skip record if offset verification fails after processing envelope (107 milliseconds)

406[info] A Slick grouped projection

407[info] - must persist projection and offset in the same write operation (transactional) (114 milliseconds)

408[info] - must handle grouped async projection and store offset (107 milliseconds)

409[info] A Slick at-least-once projection

410[info] - must persist projection and offset (113 milliseconds)

411[info] - must skip failing events when using RecoveryStrategy.skip, save after 1 (111 milliseconds)

412[info] - must skip failing events when using RecoveryStrategy.skip, save after 2 (111 milliseconds)

415[info] - must save offset after number of elements (108 milliseconds)

416[info] - must save offset after idle duration (2 seconds, 140 milliseconds)

417[info] - must verify offsets before processing an envelope (106 milliseconds)

418[info] - must skip record if offset verification fails before processing envelope (105 milliseconds)

419[info] - must handle async projection and store offset (106 milliseconds)

420[info] A Slick flow projection

421[info] - must persist projection and offset (111 milliseconds)

422[info] SlickProjection lifecycle

423[info] - must call start and stop of the handler (214 milliseconds)

424[info] - must call start and stop of the handler when using TestKit.runWithTestSink (123 milliseconds)

425[info] - must call start and stop of handler when restarted (1 second, 240 milliseconds)

426[info] - must call start and stop of handler when failed but no restart (111 milliseconds)

427[info] - must be able to stop when retrying (372 milliseconds)

428[info] SlickProjection management

429[info] - must restart from beginning when offset is cleared (64 milliseconds)

430[info] - must restart from updated offset (59 milliseconds)

431[info] - must pause projection (582 milliseconds)

432Starting build for ProjectRef(file:/build/repo/,durable-state) (pekko-projection-durable-state)... [8/10]

433Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

434[info] compiling 2 Scala sources to /build/repo/durable-state/target/scala-3.8.0-RC4/classes ...

435[info] done compiling

436[info] compiling 1 Scala source to /build/repo/durable-state/target/scala-3.8.0-RC4/test-classes ...

437[info] done compiling

438SLF4J(W): No SLF4J providers were found.

439SLF4J(W): Defaulting to no-operation (NOP) logger implementation

440SLF4J(W): See https://www.slf4j.org/codes.html#noProviders for further details.

441[info] DurableStateSourceProviderSpec:

442[info] A DurableStateSourceProvider

443[info] - must provide changes by tag (128 milliseconds)

444Starting build for ProjectRef(file:/build/repo/,core-test) (pekko-projection-core-test)... [9/10]

445Compile scalacOptions: -Wconf:msg=can be rewritten automatically under:s, -source:3.8

446SLF4J(W): A number (95) of logging calls during the initialization phase have been intercepted and are

447SLF4J(W): now being replayed. These are subject to the filtering rules of the underlying logging system.

448SLF4J(W): See also https://www.slf4j.org/codes.html#replay

449[info] WaitTimeMetricSpec:

450[info] OffsetCommittedCounterMetricAtLeastOnceSpec:

451[info] A metric counting offsets committed

452[info] must in `at-least-once` with singleHandler

453[info] - must count offsets (without afterEnvelops optimization) (281 milliseconds)

454[info] - must count offsets (with afterEnvelops optimization) (104 milliseconds)

455[info] - must count offsets only once in case of failure (504 milliseconds)

456[info] must in `at-least-once` with groupedHandler

457[info] - must count offsets (without afterEnvelops optimization) (103 milliseconds)

458[info] - must count offsets (with afterEnvelops optimization) (102 milliseconds)

459[info] - must count envelopes only once in case of failure (201 milliseconds)

460[info] must in `at-least-once` with flowHandler

461[info] - must count offsets (102 milliseconds)

462[info] - must count offsets only once in case of failure (302 milliseconds)

463[info] ProjectionBehaviorSpec:

464[info] A ProjectionBehavior

465[info] - must start immediately on demand (190 milliseconds)

466[info] - must stop after receiving stop message (17 milliseconds)

467[info] - must stop after stopping actor without stop message (8 milliseconds)

468[info] - must also stop when stopping underlying stream results in failure (3 milliseconds)

469[info] - must provide access to current offset (27 milliseconds)

470[info] - must support update of current offset (14 milliseconds)

471[info] - must handle offset operations sequentially (257 milliseconds)

472[info] - must support pause/resume (23 milliseconds)

473[info] - must handle pause/resume operations sequentially (15 milliseconds)

474[info] - must work with ProjectionManagement extension (773 milliseconds)

475[info] HandlerRecoveryImplSpec:

476[info] HandlerRecovery

477[info] - must fail (39 milliseconds)

478[info] - must skip (8 milliseconds)

479[info] - must retryAndFail 1 (46 milliseconds)

480[info] - must retryAndFail 3 (116 milliseconds)

481[info] - must retryAndFail after delay (1 second, 19 milliseconds)

482[info] - must retryAndSkip 1 (60 milliseconds)

483[info] - must retryAndSkip 3 (140 milliseconds)

484[info] - must abort retryAndFail before first attempt (1 millisecond)

485[info] ServiceTimeAndProcessingCountMetricAtLeastOnceSpec:

486[info] A metric reporting ServiceTime

487[info] must in `at-least-once` with singleHandler

488[info] - must reports measures for all envelopes (without afterEnvelops optimization) (281 milliseconds)

489[info] - must reports measures for all envelopes (with afterEnvelops optimization) (106 milliseconds)

490[info] - must reports measures for all envelopes (multiple times when there are failures) (203 milliseconds)

491[info] must in `at-least-once` with groupedHandler

492[info] - must report measures for each envelope (without afterEnvelops optimization) (101 milliseconds)

493[info] - must report measures per envelope (with afterEnvelops optimization) (101 milliseconds)

494[info] - must report multiple measures per envelope in case of failure (recovery == fail) (302 milliseconds)

495[info] - must report multiple measures per envelope in case of failure (recovery == retryAndSkip) (202 milliseconds)

496[info] must in `at-least-once` with flowHandler

497[info] - must report a measure per envelope (102 milliseconds)

498[info] - must report multiple measures per envelope in case of failure (217 milliseconds)

499[info] OffsetSerializationSpec:

500[info] OffsetSerialization

501[info] - must convert offsets of type Long (24 milliseconds)

502[info] - must convert offsets of type java.lang.Long (0 milliseconds)

503[info] - must convert offsets of type Int (1 millisecond)

504[info] - must convert offsets of type java.lang.Integer (0 milliseconds)

505[info] - must convert offsets of type String (0 milliseconds)

506[info] - must convert offsets of type org.apache.pekko.persistence.query.Sequence (6 milliseconds)

507[info] - must convert offsets of type org.apache.pekko.persistence.query.TimeBasedUUID (4 milliseconds)

508[info] - must convert other offsets types with Pekko Serialization (3 milliseconds)

509[info] OffsetSerialization of MergeableOffsets

510[info] - must convert offsets of type MergeableOffset (3 milliseconds)

511[info] - must merge rows into one MergeableOffset (0 milliseconds)

512[info] StatusObserverExactlyOnceSpec:

513[info] A metric reporting ServiceTime

514[info] must in `exactly-once` with singleHandler

515[info] - must report only one measure per envelope (278 milliseconds)

516[info] - must report only one measure per envelope even in case of failure (606 milliseconds)

517[info] must in `exactly-once` with groupedHandler

518[info] - must report only one measure per envelope (102 milliseconds)

519[info] - must report only one measure per envelope even in case of failure (recovery is fail) (104 milliseconds)

520[info] - must report only one measure per envelope even in case of failure (recovery is skip) (102 milliseconds)

521[info] TelemetryProviderNoopSpec:

522[info] TelemetryProvider

523[info] - must provide a Noop when no implementation is set (26 milliseconds)

524[info] ErrorRateMetricAtLeastOnceSpec:

525[info] A metric reporting event handler errors

526[info] must in `at-least-once` with singleHandler

527[info] - must report nothing in happy scenarios (768 milliseconds)

528[info] - must report errors in flaky handlers (452 milliseconds)

529[info] must in `at-least-once` with groupedHandler

530[info] - must report nothing in happy scenarios (1 second, 104 milliseconds)

531[info] - must report errors in flaky handlers (716 milliseconds)

532[info] must in `at-least-once` with flowHandler

533[info] - must report nothing in happy scenarios (603 milliseconds)

534[info] - must report errors in flaky handlers (217 milliseconds)

535[info] ServiceTimeAndProcessingCountMetricExactlyOnceSpec:

536[info] A metric reporting ServiceTime

537[info] must in `exactly-once` with singleHandler

538[info] - must report only one measure per envelope (265 milliseconds)

539[info] - must report only one measure per envelope even in case of failure (610 milliseconds)

540[info] must in `exactly-once` with groupedHandler

541[info] - must report only one measure per envelope (102 milliseconds)

542[info] - must report only one measure per envelope even in case of failure (recovery is fail) (102 milliseconds)

543[info] - must report only one measure per envelope even in case of failure (recovery is skip) (102 milliseconds)

544[info] LifecycleMetricAtLeastOnceSpec:

545[info] A metric reporting projection lifecycle metrics

546[info] must in `at-least-once` with singleHandler

547[info] - must count a start and a stop (780 milliseconds)

548[info] - must count projection failures (1 second, 304 milliseconds)

549[info] must in `at-least-once` with groupedHandler

550[info] - must report nothing in happy scenarios (1 second, 104 milliseconds)

551[info] must in `at-least-once` with flowHandler

552[info] - must report nothing in happy scenarios (603 milliseconds)

553[info] WaitTimeMetricAtLeastOnceSpec:

554[info] A metric reporting Wait Time

555[info] must in `at-least-once` with singleHandler

556[info] - must report the creation time (280 milliseconds)

557[info] - must report the creation time under failing scenarios (718 milliseconds)

558[info] must in `at-least-once` with groupedHandler

559[info] - must report the creation time (104 milliseconds)

560[info] must in `at-least-once` with flowHandler

561[info] - must report the creation time (4 milliseconds)

562[info] ErrorRateMetricAtMostOnceSpec:

563[info] A metric reporting event handler errors

564[info] must in `at-most-once` with singleHandler

565[info] - must report nothing in happy scenarios (272 milliseconds)

566[info] - must report nothing in case of failure (103 milliseconds)

567[info] LifecycleMetricSpec:

568[info] TelemetryProviderSingleSpec:

569[info] TelemetryProvider

570[info] - must provide the request impl when a single implementation is set (25 milliseconds)

571[info] StatusObserverAtMostOnceSpec:

572[info] A metric reporting ServiceTime

573[info] must in `at-most-once` with singleHandler

574[info] - must report measures (277 milliseconds)

575[info] - must report measures if envelopes were processed in case of failure (318 milliseconds)

576[info] OffsetCommittedCounterMetricExactlyOnceSpec:

577[info] A metric counting offsets committed

578[info] must in `exactly-once` with singleHandler

579[info] - must count offsets (271 milliseconds)

580[info] - must count offsets only once in case of failure (519 milliseconds)

581[info] must in `exactly-once` with groupedHandler

582[info] - must count offsets (102 milliseconds)

583[info] - must count offsets only once in case of failure (202 milliseconds)

584[info] TelemetryProviderEnsembleSpec:

585[info] TelemetryProvider

586[info] - must provide an ensemble impl when multiple implementations are set (28 milliseconds)

587[info] - must propagate the correct context in beforeProcess/afterProcess when multiple implementations are set (10 milliseconds)

588[info] TelemetryProviderEmptySpec:

589[info] TelemetryProvider

590[info] - must provide a Noop when the implementation list is empty (16 milliseconds)

591[info] ServiceTimeAndProcessingCountMetricAtMostOnceSpec:

592[info] A metric reporting ServiceTime

593[info] must in `at-most-once` with singleHandler

594[info] - must report measures (279 milliseconds)

595[info] - must report measures if envelopes were processed in case of failure (304 milliseconds)

596[info] ProjectionSerializerSpec:

597[info] ProjectionSerializer

598[info] - must resolve serializer for GetOffset (24 milliseconds)

599[info] - must serialize and de-serialize GetOffset (91 milliseconds)

600[info] - must resolve serializer for CurrentOffset Some (1 millisecond)

601[info] - must serialize and de-serialize CurrentOffset Some (4 milliseconds)

602[info] - must resolve serializer for CurrentOffset None (0 milliseconds)

603[info] - must serialize and de-serialize CurrentOffset None (0 milliseconds)

604[info] - must resolve serializer for SetOffset Some (0 milliseconds)

605[info] - must serialize and de-serialize SetOffset Some (4 milliseconds)

606[info] - must resolve serializer for SetOffset None (1 millisecond)

607[info] - must serialize and de-serialize SetOffset None (0 milliseconds)

608[info] - must resolve serializer for IsPaused (1 millisecond)

609[info] - must serialize and de-serialize IsPaused (2 milliseconds)

610[info] - must resolve serializer for SetPaused true (1 millisecond)

611[info] - must serialize and de-serialize SetPaused true (4 milliseconds)

612[info] - must resolve serializer for SetPaused false (0 milliseconds)

613[info] - must serialize and de-serialize SetPaused false (1 millisecond)

614[info] ErrorRateMetricExactlyOnceSpec:

615[info] A metric reporting event handler errors

616[info] must in `exactly-once` with singleHandler

617[info] - must report nothing in happy scenarios (278 milliseconds)

618[info] - must report errors in flaky handlers (610 milliseconds)

619[info] must in `exactly-once` with groupedHandler

620[info] - must report nothing in happy scenarios (602 milliseconds)

621[info] - must report errors in flaky handlers (702 milliseconds)

622[info] OffsetCommittedCounterMetricAtMostOnceSpec:

623[info] A metric counting offsets committed

624[info] must in `at-most-once` with singleHandler

625[info] - must count offsets (278 milliseconds)

626[info] - must count offsets once in case of failure (skip) (102 milliseconds)

627[info] - must count offsets once in case of failure (fail) (219 milliseconds)

628[info] StatusObserverAtLeastOnceSpec:

629[info] A StatusObserver reporting before and after the event handler

630[info] must in `at-least-once` with singleHandler

631[info] - must reports measures for all envelopes (without afterEnvelops optimizationt ) (270 milliseconds)

632[info] - must reports measures for all envelopes (with afterEnvelopes optimization) (105 milliseconds)

633[info] - must reports measures for all envelopes (multiple times when there are failures) (203 milliseconds)

634[info] must in `at-least-once` with groupedHandler

635[info] - must report measures for each envelope (without afterEnvelops optimization) (103 milliseconds)

636[info] - must report multiple measures per envelope in case of failure (recovery == fail) (302 milliseconds)

637[info] - must report multiple measures per envelope in case of failure (recovery == retryAndSkip) (102 milliseconds)

638[info] must in `at-least-once` with flowHandler

639[info] - must report a measure per envelope (104 milliseconds)

640[info] - must report multiple measures per envelope in case of failure (219 milliseconds)

641[info] - must abort retryAndFail when retrying (3 seconds, 139 milliseconds)

643************************

644Build summary:

645[{

646 "module": "pekko-projection-jdbc",

647 "compile": {"status": "ok", "tookMs": 16982, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

648 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

649 "test-compile": {"status": "ok", "tookMs": 13407, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

650 "test": {"status": "ok", "tookMs": 2566, "passed": 28, "failed": 0, "ignored": 0, "skipped": 0, "total": 28, "byFramework": [{"framework": "unknown", "stats": {"passed": 28, "failed": 0, "ignored": 0, "skipped": 0, "total": 28}}]},

651 "publish": {"status": "skipped", "tookMs": 0},

652 "metadata": {

653 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

654}

655},{

656 "module": "pekko-projection-eventsourced",

657 "compile": {"status": "ok", "tookMs": 835, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

658 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

659 "test-compile": {"status": "ok", "tookMs": 1115, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

660 "test": {"status": "ok", "tookMs": 2092, "passed": 4, "failed": 0, "ignored": 0, "skipped": 0, "total": 4, "byFramework": [{"framework": "unknown", "stats": {"passed": 4, "failed": 0, "ignored": 0, "skipped": 0, "total": 4}}]},

661 "publish": {"status": "skipped", "tookMs": 0},

662 "metadata": {

663 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

664}

665},{

666 "module": "pekko-projection-bom",

667 "compile": {"status": "ok", "tookMs": 59, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

668 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

669 "test-compile": {"status": "ok", "tookMs": 83, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

670 "test": {"status": "ok", "tookMs": 65, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

671 "publish": {"status": "skipped", "tookMs": 0},

672 "metadata": {

673 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

674}

675},{

676 "module": "pekko-projection-cassandra",

677 "compile": {"status": "ok", "tookMs": 918, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

678 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

679 "test-compile": {"status": "ok", "tookMs": 306, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

680 "test": {"status": "ok", "tookMs": 293, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

681 "publish": {"status": "skipped", "tookMs": 0},

682 "metadata": {

683 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

684}

685},{

686 "module": "pekko-projection-core",

687 "compile": {"status": "ok", "tookMs": 60, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

688 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

689 "test-compile": {"status": "ok", "tookMs": 110, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

690 "test": {"status": "ok", "tookMs": 107, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

691 "publish": {"status": "skipped", "tookMs": 0},

692 "metadata": {

693 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

694}

695},{

696 "module": "pekko-projection-testkit",

697 "compile": {"status": "ok", "tookMs": 105, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

698 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

699 "test-compile": {"status": "ok", "tookMs": 1664, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

700 "test": {"status": "ok", "tookMs": 9928, "passed": 13, "failed": 0, "ignored": 0, "skipped": 0, "total": 13, "byFramework": [{"framework": "unknown", "stats": {"passed": 13, "failed": 0, "ignored": 0, "skipped": 0, "total": 13}}]},

701 "publish": {"status": "skipped", "tookMs": 0},

702 "metadata": {

703 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

704}

705},{

706 "module": "pekko-projection-kafka",

707 "compile": {"status": "ok", "tookMs": 813, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

708 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

709 "test-compile": {"status": "ok", "tookMs": 165, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

710 "test": {"status": "ok", "tookMs": 151, "passed": 0, "failed": 0, "ignored": 0, "skipped": 0, "total": 0, "byFramework": []},

711 "publish": {"status": "skipped", "tookMs": 0},

712 "metadata": {

713 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

714}

715},{

716 "module": "pekko-projection-slick",

717 "compile": {"status": "ok", "tookMs": 1676, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

718 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

719 "test-compile": {"status": "ok", "tookMs": 4167, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

720 "test": {"status": "ok", "tookMs": 9206, "passed": 45, "failed": 0, "ignored": 0, "skipped": 0, "total": 45, "byFramework": [{"framework": "unknown", "stats": {"passed": 45, "failed": 0, "ignored": 0, "skipped": 0, "total": 45}}]},

721 "publish": {"status": "skipped", "tookMs": 0},

722 "metadata": {

723 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

724}

725},{

726 "module": "pekko-projection-durable-state",

727 "compile": {"status": "ok", "tookMs": 603, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

728 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

729 "test-compile": {"status": "ok", "tookMs": 912, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

730 "test": {"status": "ok", "tookMs": 851, "passed": 1, "failed": 0, "ignored": 0, "skipped": 0, "total": 1, "byFramework": [{"framework": "unknown", "stats": {"passed": 1, "failed": 0, "ignored": 0, "skipped": 0, "total": 1}}]},

731 "publish": {"status": "skipped", "tookMs": 0},

732 "metadata": {

733 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

734}

735},{

736 "module": "pekko-projection-core-test",

737 "compile": {"status": "ok", "tookMs": 84, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

738 "doc": {"status": "skipped", "tookMs": 0, "files": 0, "totalSizeKb": 0},

739 "test-compile": {"status": "ok", "tookMs": 163, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

740 "test": {"status": "ok", "tookMs": 5532, "passed": 116, "failed": 0, "ignored": 0, "skipped": 0, "total": 116, "byFramework": [{"framework": "unknown", "stats": {"passed": 116, "failed": 0, "ignored": 0, "skipped": 0, "total": 116}}]},

741 "publish": {"status": "ok", "tookMs": 2},

742 "metadata": {

743 "crossScalaVersions": ["2.13.16", "2.12.20", "3.3.5"]

744}

745}]

746************************

747[success] Total time: 151 s (0:02:31.0), completed Dec 22, 2025, 6:29:41 PM

748[0JChecking patch project/plugins.sbt...

749Checking patch project/build.properties...

750Checking patch project/Dependencies.scala...

751Checking patch build.sbt...

752Applied patch project/plugins.sbt cleanly.

753Applied patch project/build.properties cleanly.

754Applied patch project/Dependencies.scala cleanly.

755Applied patch build.sbt cleanly.