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

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

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

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

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

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

70"++3.8.0-RC6 -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-RC6 """{"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.921s.

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

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

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

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

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

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

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

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

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

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

204OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in jdbc/crossScalaVersions

205OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in docs/crossScalaVersions

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

207OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in testkit/crossScalaVersions

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

209OpenCB::Changing crossVersion 3.8.0-RC6 -> 3.8.0-RC6 in examples/crossScalaVersions

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

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

212[info] Switching Scala version on:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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 Jan 8, 2026, 2:00:00 AM

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-RC6/classes ...

265[info] done compiling

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

267[info] done compiling

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

279[info] - atLeastOnceFlowShouldStoreOffset

280# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@6541c845

281[info] - atLeastOnceShouldStoreOffset

282# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@2f1337c6

283[info] - exactlyOnceShouldStoreOffset

284[info] - exactlyOnceShouldRestartFromPreviousOffset

285# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@3dbfd74f

286[info] - atLeastOnceShouldRestartFromPreviousOffset

287# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@5ea9dd05

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 (167 milliseconds)

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

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

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

299[info] H2JdbcOffsetStoreSpec:

300[info] The JdbcOffsetStore

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

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

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

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

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

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

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

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

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

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

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

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

313[info] - must clear offset [H2 Database] (7 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-RC6/classes ...

318[info] done compiling

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

320[info] done compiling

321[info] EventSourcedProviderSpec:

322[info] Should provide different events

323[info] by tags

324[info] - for different tags (461 milliseconds)

325[info] - for different journals (251 milliseconds)

326[info] by slices

327[info] - for different slices (360 milliseconds)

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

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

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

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

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

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

334[info] done compiling

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

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

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

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

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

340[info] done compiling

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

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

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

344[info] ProjectionTestKitTest:

345[info] - failureInsideStreamPropagatesToTestkit

346[info] ProjectionTestKitSpec:

347[info] ProjectionTestKit

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

349[info] - must retry assertion function until it succeeds within a max timeout (1 second, 311 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 (199 milliseconds)

354[info] - failureInsideProjectionPropagatesToTestkit

355[info] - assertProgressOfAProjection

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

357[info] - retryAssertionFunctionAndFailWhenTimeoutExpires

358[info] - runAProjectionWithATestSink

359[info] - retryAssertionFunctionUntilItSucceedsWithinAMaxTimeout

360[info] - must failure inside Stream propagates to TestKit (2 seconds, 913 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-RC6/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-RC6/classes ...

369[info] done compiling

370[info] compiling 2 Scala sources to /build/repo/slick/target/scala-3.8.0-RC6/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] (12 milliseconds)

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

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

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

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

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

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

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

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

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

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

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

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

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

391[info] SlickProjectionSpec:

392[info] A Slick exactly-once projection

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

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

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

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

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

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

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

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

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

403[info] A Slick grouped projection

404[info] - must persist projection and offset in the same write operation (transactional) (114 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 (113 milliseconds)

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

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

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

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

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

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

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

417[info] A Slick flow projection

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

419[info] SlickProjection lifecycle

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

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

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

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

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

425[info] SlickProjection management

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

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

428[info] - must pause projection (576 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-RC6/classes ...

432[info] done compiling

433[info] compiling 1 Scala source to /build/repo/durable-state/target/scala-3.8.0-RC6/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 (136 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 (95) 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] LifecycleMetricSpec:

447[info] HandlerRecoveryImplSpec:

448[info] HandlerRecovery

449[info] - must fail (41 milliseconds)

450[info] - must skip (5 milliseconds)

451[info] - must retryAndFail 1 (38 milliseconds)

452[info] - must retryAndFail 3 (123 milliseconds)

453[info] - must retryAndFail after delay (1 second, 20 milliseconds)

454[info] - must retryAndSkip 1 (59 milliseconds)

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

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

457[info] StatusObserverAtLeastOnceSpec:

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

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

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

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

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

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

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

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

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

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

468[info] - must report a measure per envelope (114 milliseconds)

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

470[info] TelemetryProviderNoopSpec:

471[info] TelemetryProvider

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

473[info] OffsetCommittedCounterMetricExactlyOnceSpec:

474[info] A metric counting offsets committed

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

476[info] - must count offsets (244 milliseconds)

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

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

479[info] - must count offsets (105 milliseconds)

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

481[info] ErrorRateMetricExactlyOnceSpec:

482[info] A metric reporting event handler errors

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

484[info] - must report nothing in happy scenarios (237 milliseconds)

485[info] - must report errors in flaky handlers (624 milliseconds)

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

487[info] - must report nothing in happy scenarios (547 milliseconds)

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

489[info] OffsetSerializationSpec:

490[info] OffsetSerialization

491[info] - must convert offsets of type Long (17 milliseconds)

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

493[info] - must convert offsets of type Int (0 milliseconds)

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

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

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

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

498[info] - must convert other offsets types with Pekko Serialization (2 milliseconds)

499[info] OffsetSerialization of MergeableOffsets

500[info] - must convert offsets of type MergeableOffset (13 milliseconds)

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

502[info] LifecycleMetricAtLeastOnceSpec:

503[info] A metric reporting projection lifecycle metrics

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

505[info] - must count a start and a stop (741 milliseconds)

506[info] - must count projection failures (1 second, 309 milliseconds)

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

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

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

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

511[info] ProjectionSerializerSpec:

512[info] ProjectionSerializer

513[info] - must resolve serializer for GetOffset (21 milliseconds)

514[info] - must serialize and de-serialize GetOffset (96 milliseconds)

515[info] - must resolve serializer for CurrentOffset Some (0 milliseconds)

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

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

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

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

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

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

522[info] - must serialize and de-serialize SetOffset None (1 millisecond)

523[info] - must resolve serializer for IsPaused (0 milliseconds)

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

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

526[info] - must serialize and de-serialize SetPaused true (3 milliseconds)

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

528[info] - must serialize and de-serialize SetPaused false (0 milliseconds)

529[info] TelemetryProviderSingleSpec:

530[info] TelemetryProvider

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

532[info] OffsetCommittedCounterMetricAtLeastOnceSpec:

533[info] A metric counting offsets committed

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

535[info] - must count offsets (without afterEnvelops optimization) (239 milliseconds)

536[info] - must count offsets (with afterEnvelops optimization) (101 milliseconds)

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

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

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

540[info] - must count offsets (with afterEnvelops optimization) (101 milliseconds)

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

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

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

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

545[info] ServiceTimeAndProcessingCountMetricAtMostOnceSpec:

546[info] A metric reporting ServiceTime

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

548[info] - must report measures (252 milliseconds)

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

550[info] ErrorRateMetricAtMostOnceSpec:

551[info] A metric reporting event handler errors

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

553[info] - must report nothing in happy scenarios (252 milliseconds)

554[info] - must report nothing in case of failure (102 milliseconds)

555[info] ErrorRateMetricAtLeastOnceSpec:

556[info] A metric reporting event handler errors

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

558[info] - must report nothing in happy scenarios (739 milliseconds)

559[info] - must report errors in flaky handlers (505 milliseconds)

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

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

562[info] - must report errors in flaky handlers (721 milliseconds)

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

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

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

566[info] ServiceTimeAndProcessingCountMetricAtLeastOnceSpec:

567[info] A metric reporting ServiceTime

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

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

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

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

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

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

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

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

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

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

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

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

580[info] WaitTimeMetricSpec:

581[info] StatusObserverAtMostOnceSpec:

582[info] A metric reporting ServiceTime

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

584[info] - must report measures (257 milliseconds)

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

586[info] StatusObserverExactlyOnceSpec:

587[info] A metric reporting ServiceTime

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

589[info] - must report only one measure per envelope (248 milliseconds)

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

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

592[info] - must report only one measure per envelope (104 milliseconds)

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

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

595[info] ProjectionBehaviorSpec:

596[info] A ProjectionBehavior

597[info] - must start immediately on demand (176 milliseconds)

598[info] - must stop after receiving stop message (20 milliseconds)

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

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

601[info] - must provide access to current offset (23 milliseconds)

602[info] - must support update of current offset (21 milliseconds)

603[info] - must handle offset operations sequentially (267 milliseconds)

604[info] - must support pause/resume (20 milliseconds)

605[info] - must handle pause/resume operations sequentially (21 milliseconds)

606[info] - must work with ProjectionManagement extension (562 milliseconds)

607[info] ServiceTimeAndProcessingCountMetricExactlyOnceSpec:

608[info] A metric reporting ServiceTime

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

610[info] - must report only one measure per envelope (250 milliseconds)

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

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

613[info] - must report only one measure per envelope (104 milliseconds)

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

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

616[info] TelemetryProviderEmptySpec:

617[info] TelemetryProvider

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

619[info] TelemetryProviderEnsembleSpec:

620[info] TelemetryProvider

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

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

623[info] OffsetCommittedCounterMetricAtMostOnceSpec:

624[info] A metric counting offsets committed

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

626[info] - must count offsets (260 milliseconds)

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

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

629[info] WaitTimeMetricAtLeastOnceSpec:

630[info] A metric reporting Wait Time

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

632[info] - must report the creation time (266 milliseconds)

633[info] - must report the creation time under failing scenarios (743 milliseconds)

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

635[info] - must report the creation time (107 milliseconds)

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

637[info] - must report the creation time (7 milliseconds)

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

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

641Build summary:

642[{

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

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

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

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

647 "test": {"status": "ok", "tookMs": 2614, "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": 891, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

657 "test": {"status": "ok", "tookMs": 2326, "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": 53, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

667 "test": {"status": "ok", "tookMs": 58, "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": 760, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

677 "test": {"status": "ok", "tookMs": 286, "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": 47, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

687 "test": {"status": "ok", "tookMs": 91, "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": 1489, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

697 "test": {"status": "ok", "tookMs": 9992, "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": 889, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

707 "test": {"status": "ok", "tookMs": 150, "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": 1962, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

717 "test": {"status": "ok", "tookMs": 9151, "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": 553, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

727 "test": {"status": "ok", "tookMs": 863, "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": 86, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

737 "test": {"status": "ok", "tookMs": 5559, "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": 3},

739 "metadata": {

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

741}

742}]

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

744[success] Total time: 87 s (0:01:27.0), completed Jan 8, 2026, 2:01:27 AM

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.