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-RC5

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-RC5"

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-RC5

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-RC5

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-RC5

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-RC5"

70"++3.8.0-RC5 -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-RC5 """{"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.992s.

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-RC5

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

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

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

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

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

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

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

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

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

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

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

206OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in kafka/crossScalaVersions

207OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in examples/crossScalaVersions

208OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in bill-of-materials/crossScalaVersions

209OpenCB::Changing crossVersion 3.8.0-RC5 -> 3.8.0-RC5 in testkit/crossScalaVersions

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

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

212[info] Switching Scala version on:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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 31, 2025, 9:08:26 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-RC5/classes ...

265[info] done compiling

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

267[info] done compiling

268[info] compiling 13 Scala sources to /build/repo/testkit/target/scala-3.8.0-RC5/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-RC5/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-RC5/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@1797940e

279[info] - atLeastOnceFlowShouldStoreOffset

280# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@5936c47e

281[info] - atLeastOnceShouldStoreOffset

282# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@5e3985c8

283[info] - exactlyOnceShouldStoreOffset

284[info] - exactlyOnceShouldRestartFromPreviousOffset

285# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@8ffabab

286[info] - atLeastOnceShouldRestartFromPreviousOffset

287# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@7fb5be37

288[info] - groupedShouldStoreOffset

289[info] H2JdbcOffsetStoreSpec:

290[info] The JdbcOffsetStore

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

292[info] - must create and update offsets [H2 Database] (65 milliseconds)

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

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

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

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

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

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

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

300[info] - must save and retrieve MergeableOffset [H2 Database] (15 milliseconds)

301[info] - must add new offsets to MergeableOffset [H2 Database] (11 milliseconds)

302[info] - must update timestamp [H2 Database] (7 milliseconds)

303[info] - must clear offset [H2 Database] (7 milliseconds)

304[info] - must read and save paused [H2 Database] (10 milliseconds)

305[info] JdbcSettingsSpec:

306[info] Loading JdbcSettings

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

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

309[info] - must accept a correctly filled pool size (51 milliseconds)

314[info] - must dont' fail if user decide to step out of a thread-pool-executor (76 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-RC5/classes ...

318[info] done compiling

319[info] compiling 1 Scala source to /build/repo/eventsourced/target/scala-3.8.0-RC5/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 (442 milliseconds)

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

329[info] by slices

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

331[info] - for different journals (244 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-RC5/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-RC5/test-classes ...

343[info] done compiling

344[info] ProjectionTestKitTest:

345[info] - failureInsideStreamPropagatesToTestkit

346[info] ProjectionTestKitSpec:

347[info] ProjectionTestKit

348[info] - must assert progress of a projection (186 milliseconds)

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

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

351[info] TestProjectionSpec:

352[info] TestProjection

353[info] - must run an ActorHandler (190 milliseconds)

354[info] - failureInsideProjectionPropagatesToTestkit

355[info] - assertProgressOfAProjection

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

357[info] - retryAssertionFunctionAndFailWhenTimeoutExpires

358[info] - runAProjectionWithATestSink

359[info] - retryAssertionFunctionUntilItSucceedsWithinAMaxTimeout

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

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

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

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

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

365[info] done compiling

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

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

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

369[info] done compiling

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

371[info] done compiling

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

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

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

375[info] H2SlickOffsetStoreSpec:

376[info] The SlickOffsetStore

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

378[info] - must create and update offsets [H2 Database] (150 milliseconds)

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

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

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

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

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

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

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

386[info] - must update timestamp [H2 Database] (30 milliseconds)

387[info] - must save and retrieve MergeableOffset [H2 Database] (21 milliseconds)

388[info] - must add new offsets to MergeableOffset [H2 Database] (28 milliseconds)

389[info] - must clear offset [H2 Database] (32 milliseconds)

390[info] - must read and save paused [H2 Database] (24 milliseconds)

391[info] SlickProjectionSpec:

392[info] A Slick exactly-once projection

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

394[info] - must skip failing events when using RecoveryStrategy.skip (121 milliseconds)

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

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

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

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

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

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

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

403[info] A Slick grouped projection

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

405[info] - must handle grouped async projection and store offset (108 milliseconds)

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

407[info] - must persist projection and offset (115 milliseconds)

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

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

412[info] - must save offset after number of elements (124 milliseconds)

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

414[info] - must verify offsets before processing an envelope (107 milliseconds)

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

416[info] - must handle async projection and store offset (105 milliseconds)

417[info] A Slick flow projection

418[info] - must persist projection and offset (112 milliseconds)

419[info] SlickProjection lifecycle

420[info] - must call start and stop of the handler (217 milliseconds)

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

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

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

424[info] - must be able to stop when retrying (373 milliseconds)

425[info] SlickProjection management

426[info] - must restart from beginning when offset is cleared (63 milliseconds)

427[info] - must restart from updated offset (47 milliseconds)

428[info] - must pause projection (577 milliseconds)

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

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

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

432[info] done compiling

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

434[info] done compiling

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

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

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

438[info] DurableStateSourceProviderSpec:

439[info] A DurableStateSourceProvider

440[info] - must provide changes by tag (170 milliseconds)

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

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

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

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

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

446[info] WaitTimeMetricSpec:

447[info] ProjectionSerializerSpec:

448[info] ProjectionSerializer

449[info] - must resolve serializer for GetOffset (32 milliseconds)

450[info] - must serialize and de-serialize GetOffset (100 milliseconds)

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

452[info] - must serialize and de-serialize CurrentOffset Some (6 milliseconds)

453[info] - must resolve serializer for CurrentOffset None (1 millisecond)

454[info] - must serialize and de-serialize CurrentOffset None (1 millisecond)

455[info] - must resolve serializer for SetOffset Some (1 millisecond)

456[info] - must serialize and de-serialize SetOffset Some (3 milliseconds)

457[info] - must resolve serializer for SetOffset None (0 milliseconds)

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

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

460[info] - must serialize and de-serialize IsPaused (3 milliseconds)

461[info] - must resolve serializer for SetPaused true (0 milliseconds)

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

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

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

465[info] TelemetryProviderEmptySpec:

466[info] TelemetryProvider

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

468[info] StatusObserverAtLeastOnceSpec:

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

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

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

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

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

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

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

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

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

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

479[info] - must report a measure per envelope (103 milliseconds)

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

481[info] LifecycleMetricSpec:

482[info] ErrorRateMetricAtLeastOnceSpec:

483[info] A metric reporting event handler errors

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

485[info] - must report nothing in happy scenarios (794 milliseconds)

486[info] - must report errors in flaky handlers (448 milliseconds)

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

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

489[info] - must report errors in flaky handlers (713 milliseconds)

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

491[info] TelemetryProviderNoopSpec:

492[info] TelemetryProvider

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

494[info] ServiceTimeAndProcessingCountMetricAtMostOnceSpec:

495[info] A metric reporting ServiceTime

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

497[info] - must report measures (283 milliseconds)

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

499[info] OffsetCommittedCounterMetricAtMostOnceSpec:

500[info] A metric counting offsets committed

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

502[info] - must count offsets (289 milliseconds)

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

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

505[info] StatusObserverExactlyOnceSpec:

506[info] A metric reporting ServiceTime

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

508[info] - must report only one measure per envelope (292 milliseconds)

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

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

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

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

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

514[info] StatusObserverAtMostOnceSpec:

515[info] A metric reporting ServiceTime

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

517[info] - must report measures (293 milliseconds)

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

519[info] OffsetCommittedCounterMetricAtLeastOnceSpec:

520[info] A metric counting offsets committed

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

522[info] - must count offsets (without afterEnvelops optimization) (284 milliseconds)

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

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

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

526[info] - must count offsets (without afterEnvelops optimization) (102 milliseconds)

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

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

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

530[info] - must count offsets (101 milliseconds)

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

532[info] ErrorRateMetricExactlyOnceSpec:

533[info] A metric reporting event handler errors

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

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

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

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

538[info] - must report nothing in happy scenarios (604 milliseconds)

539[info] - must report errors in flaky handlers (704 milliseconds)

540[info] OffsetCommittedCounterMetricExactlyOnceSpec:

541[info] A metric counting offsets committed

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

543[info] - must count offsets (289 milliseconds)

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

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

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

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

548[info] WaitTimeMetricAtLeastOnceSpec:

549[info] A metric reporting Wait Time

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

551[info] - must report the creation time (298 milliseconds)

552[info] - must report the creation time under failing scenarios (719 milliseconds)

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

554[info] - must report the creation time (102 milliseconds)

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

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

557[info] TelemetryProviderEnsembleSpec:

558[info] TelemetryProvider

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

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

561[info] - must report nothing in happy scenarios (604 milliseconds)

562[info] LifecycleMetricAtLeastOnceSpec:

563[info] A metric reporting projection lifecycle metrics

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

565[info] - must count a start and a stop (790 milliseconds)

566[info] - must count projection failures (1 second, 305 milliseconds)

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

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

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

570[info] - must report nothing in happy scenarios (604 milliseconds)

571[info] ErrorRateMetricAtMostOnceSpec:

572[info] A metric reporting event handler errors

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

574[info] - must report nothing in happy scenarios (276 milliseconds)

575[info] - must report nothing in case of failure (107 milliseconds)

576[info] - must report errors in flaky handlers (223 milliseconds)

577[info] HandlerRecoveryImplSpec:

578[info] HandlerRecovery

579[info] - must fail (63 milliseconds)

580[info] - must skip (9 milliseconds)

581[info] - must retryAndFail 1 (41 milliseconds)

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

583[info] - must retryAndFail after delay (1 second, 18 milliseconds)

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

585[info] - must retryAndSkip 3 (139 milliseconds)

586[info] - must abort retryAndFail before first attempt (2 milliseconds)

587[info] - must abort retryAndFail when retrying (3 seconds, 138 milliseconds)

588[info] ProjectionBehaviorSpec:

589[info] A ProjectionBehavior

590[info] - must start immediately on demand (221 milliseconds)

591[info] - must stop after receiving stop message (16 milliseconds)

592[info] - must stop after stopping actor without stop message (6 milliseconds)

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

594[info] - must provide access to current offset (22 milliseconds)

595[info] - must support update of current offset (16 milliseconds)

596[info] - must handle offset operations sequentially (281 milliseconds)

597[info] - must support pause/resume (16 milliseconds)

598[info] - must handle pause/resume operations sequentially (18 milliseconds)

599[info] - must work with ProjectionManagement extension (547 milliseconds)

600[info] TelemetryProviderSingleSpec:

601[info] TelemetryProvider

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

603[info] ServiceTimeAndProcessingCountMetricExactlyOnceSpec:

604[info] A metric reporting ServiceTime

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

606[info] - must report only one measure per envelope (291 milliseconds)

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

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

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

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

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

612[info] ServiceTimeAndProcessingCountMetricAtLeastOnceSpec:

613[info] A metric reporting ServiceTime

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

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

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

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

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

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

620[info] - must report measures per envelope (with afterEnvelops optimization) (102 milliseconds)

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

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

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

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

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

626[info] OffsetSerializationSpec:

627[info] OffsetSerialization

628[info] - must convert offsets of type Long (43 milliseconds)

629[info] - must convert offsets of type java.lang.Long (1 millisecond)

630[info] - must convert offsets of type Int (2 milliseconds)

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

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

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

634[info] - must convert offsets of type org.apache.pekko.persistence.query.TimeBasedUUID (1 millisecond)

635[info] - must convert other offsets types with Pekko Serialization (12 milliseconds)

636[info] OffsetSerialization of MergeableOffsets

637[info] - must convert offsets of type MergeableOffset (4 milliseconds)

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

640************************

641Build summary:

642[{

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

644 "compile": {"status": "ok", "tookMs": 14854, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

649 "metadata": {

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

651}

652},{

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

654 "compile": {"status": "ok", "tookMs": 721, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

659 "metadata": {

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

661}

662},{

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

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

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

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

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

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

669 "metadata": {

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

671}

672},{

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

674 "compile": {"status": "ok", "tookMs": 816, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

679 "metadata": {

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

681}

682},{

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

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

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

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

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

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

689 "metadata": {

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

691}

692},{

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

694 "compile": {"status": "ok", "tookMs": 100, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

699 "metadata": {

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

701}

702},{

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

704 "compile": {"status": "ok", "tookMs": 774, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

709 "metadata": {

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

711}

712},{

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

714 "compile": {"status": "ok", "tookMs": 1634, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

719 "metadata": {

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

721}

722},{

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

724 "compile": {"status": "ok", "tookMs": 539, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

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

729 "metadata": {

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

731}

732},{

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

734 "compile": {"status": "ok", "tookMs": 189, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

738 "publish": {"status": "ok", "tookMs": 4},

739 "metadata": {

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

741}

742}]

743************************

744[success] Total time: 89 s (0:01:29.0), completed Dec 31, 2025, 9:09:55 PM

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

746Checking patch project/build.properties...

747Checking patch project/Dependencies.scala...

748Checking patch build.sbt...

749Applied patch project/plugins.sbt cleanly.

750Applied patch project/build.properties cleanly.

751Applied patch project/Dependencies.scala cleanly.

752Applied patch build.sbt cleanly.