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

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

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

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

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

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

70"++3.8.0-RC2 -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-RC2 """{"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.799s.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

209OpenCB::Changing crossVersion 3.8.0-RC2 -> 3.8.0-RC2 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-RC2 on 14 projects.

212[info] Switching Scala version on:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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 Nov 28, 2025, 1:53:04 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-RC2/classes ...

265[info] done compiling

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

267[info] done compiling

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

279[info] - atLeastOnceFlowShouldStoreOffset

280# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@201aa977

281[info] - atLeastOnceShouldStoreOffset

282# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@43fc4dd1

283[info] - exactlyOnceShouldStoreOffset

284[info] - exactlyOnceShouldRestartFromPreviousOffset

285# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@21329f2e

286[info] - atLeastOnceShouldRestartFromPreviousOffset

287# stop org.apache.pekko.projection.jdbc.internal.JdbcProjectionImpl$JdbcRunningProjection@67ffb3d0

288[info] - groupedShouldStoreOffset

289[info] H2JdbcOffsetStoreSpec:

290[info] The JdbcOffsetStore

291[info] - must not fail when dropIfExists and createIfNotExists are called [H2 Database] (11 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] (12 milliseconds)

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

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

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

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

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

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

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

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

303[info] - must clear offset [H2 Database] (6 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 (152 milliseconds)

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

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

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

318[info] done compiling

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

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

329[info] by slices

330[info] - for different slices (362 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-RC2/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-RC2/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] TestProjectionSpec:

348[info] TestProjection

349[info] - must run an ActorHandler (187 milliseconds)

350[info] ProjectionTestKitSpec:

351[info] ProjectionTestKit

352[info] - must assert progress of a projection (180 milliseconds)

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

354[info] ProjectionTestKitTest:

355[info] - failureInsideStreamPropagatesToTestkit

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

357[info] - failureInsideProjectionPropagatesToTestkit

358[info] - assertProgressOfAProjection

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

360[info] - retryAssertionFunctionAndFailWhenTimeoutExpires

361[info] - runAProjectionWithATestSink

362[info] - retryAssertionFunctionUntilItSucceedsWithinAMaxTimeout

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

372[info] done compiling

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

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

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

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

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

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

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

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

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

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

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

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

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

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

394[info] SlickProjectionSpec:

395[info] A Slick exactly-once projection

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

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

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

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

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

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

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

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

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

406[info] A Slick grouped projection

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

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

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

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

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

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

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

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

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

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

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

420[info] A Slick flow projection

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

422[info] SlickProjection lifecycle

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

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

425[info] - must call start and stop of handler when restarted (1 second, 237 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 (371 milliseconds)

428[info] SlickProjection management

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

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

431[info] - must pause projection (584 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-RC2/classes ...

435[info] done compiling

436[info] compiling 1 Scala source to /build/repo/durable-state/target/scala-3.8.0-RC2/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] OffsetCommittedCounterMetricAtMostOnceSpec:

451[info] A metric counting offsets committed

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

453[info] - must count offsets (264 milliseconds)

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

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

456[info] ProjectionSerializerSpec:

457[info] ProjectionSerializer

458[info] - must resolve serializer for GetOffset (22 milliseconds)

459[info] - must serialize and de-serialize GetOffset (109 milliseconds)

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

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

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

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

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

465[info] - must serialize and de-serialize SetOffset Some (2 milliseconds)

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

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

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

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

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

471[info] - must serialize and de-serialize SetPaused true (7 milliseconds)

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

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

474[info] StatusObserverAtMostOnceSpec:

475[info] A metric reporting ServiceTime

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

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

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

479[info] TelemetryProviderEmptySpec:

480[info] TelemetryProvider

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

482[info] TelemetryProviderSingleSpec:

483[info] TelemetryProvider

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

485[info] ServiceTimeAndProcessingCountMetricAtMostOnceSpec:

486[info] A metric reporting ServiceTime

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

488[info] - must report measures (278 milliseconds)

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

490[info] OffsetSerializationSpec:

491[info] OffsetSerialization

492[info] - must convert offsets of type Long (16 milliseconds)

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

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

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

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

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

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

499[info] - must convert other offsets types with Pekko Serialization (6 milliseconds)

500[info] OffsetSerialization of MergeableOffsets

501[info] - must convert offsets of type MergeableOffset (8 milliseconds)

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

503[info] OffsetCommittedCounterMetricAtLeastOnceSpec:

504[info] A metric counting offsets committed

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

506[info] - must count offsets (without afterEnvelops optimization) (275 milliseconds)

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

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

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

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

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

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

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

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

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

516[info] StatusObserverAtLeastOnceSpec:

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

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

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

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

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

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

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

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

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

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

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

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

529[info] WaitTimeMetricAtLeastOnceSpec:

530[info] A metric reporting Wait Time

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

532[info] - must report the creation time (291 milliseconds)

533[info] - must report the creation time under failing scenarios (711 milliseconds)

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

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

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

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

538[info] StatusObserverExactlyOnceSpec:

539[info] A metric reporting ServiceTime

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

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

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

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

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

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

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

547[info] ServiceTimeAndProcessingCountMetricAtLeastOnceSpec:

548[info] A metric reporting ServiceTime

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

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

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

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

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

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

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

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

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

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

559[info] - must report a measure per envelope (101 milliseconds)

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

561[info] TelemetryProviderNoopSpec:

562[info] TelemetryProvider

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

564[info] ErrorRateMetricAtMostOnceSpec:

565[info] A metric reporting event handler errors

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

567[info] - must report nothing in happy scenarios (277 milliseconds)

568[info] - must report nothing in case of failure (106 milliseconds)

569[info] LifecycleMetricAtLeastOnceSpec:

570[info] A metric reporting projection lifecycle metrics

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

572[info] - must count a start and a stop (777 milliseconds)

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

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

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

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

577[info] ProjectionBehaviorSpec:

578[info] A ProjectionBehavior

579[info] - must start immediately on demand (212 milliseconds)

580[info] - must stop after receiving stop message (19 milliseconds)

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

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

583[info] - must provide access to current offset (24 milliseconds)

584[info] - must support update of current offset (42 milliseconds)

585[info] - must handle offset operations sequentially (251 milliseconds)

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

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

588[info] - must work with ProjectionManagement extension (558 milliseconds)

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

590[info] HandlerRecoveryImplSpec:

591[info] HandlerRecovery

592[info] - must fail (52 milliseconds)

593[info] - must skip (9 milliseconds)

594[info] - must retryAndFail 1 (43 milliseconds)

595[info] - must retryAndFail 3 (118 milliseconds)

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

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

598[info] - must retryAndSkip 3 (141 milliseconds)

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

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

601[info] TelemetryProviderEnsembleSpec:

602[info] TelemetryProvider

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

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

605[info] OffsetCommittedCounterMetricExactlyOnceSpec:

606[info] A metric counting offsets committed

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

608[info] - must count offsets (277 milliseconds)

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

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

611[info] - must count offsets (103 milliseconds)

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

613[info] ServiceTimeAndProcessingCountMetricExactlyOnceSpec:

614[info] A metric reporting ServiceTime

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

616[info] - must report only one measure per envelope (277 milliseconds)

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

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

619[info] - must report only one measure per envelope (103 milliseconds)

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

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

622[info] LifecycleMetricSpec:

623[info] ErrorRateMetricAtLeastOnceSpec:

624[info] A metric reporting event handler errors

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

626[info] - must report nothing in happy scenarios (767 milliseconds)

627[info] - must report errors in flaky handlers (443 milliseconds)

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

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

630[info] - must report errors in flaky handlers (714 milliseconds)

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

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

633[info] - must report errors in flaky handlers (215 milliseconds)

634[info] ErrorRateMetricExactlyOnceSpec:

635[info] A metric reporting event handler errors

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

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

638[info] - must report errors in flaky handlers (602 milliseconds)

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

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

641[info] - must report errors in flaky handlers (703 milliseconds)

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

644Build summary:

645[{

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

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

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

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

650 "test": {"status": "ok", "tookMs": 2669, "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": 883, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

660 "test": {"status": "ok", "tookMs": 2513, "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": 77, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

670 "test": {"status": "ok", "tookMs": 75, "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": 834, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

680 "test": {"status": "ok", "tookMs": 308, "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": 66, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

690 "test": {"status": "ok", "tookMs": 105, "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": 119, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

700 "test": {"status": "ok", "tookMs": 10089, "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": 859, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

710 "test": {"status": "ok", "tookMs": 143, "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": 1985, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

720 "test": {"status": "ok", "tookMs": 9454, "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": 769, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

730 "test": {"status": "ok", "tookMs": 875, "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": 94, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

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

742 "metadata": {

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

744}

745}]

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

747[success] Total time: 141 s (0:02:21.0), completed Nov 28, 2025, 1:55:25 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.