Build Logs

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

2Clonning https://github.com/flink-extended/flink-scala-api.git into /build/repo using revision v2.0.4

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

4Note: switching to 'f7c78b53f30075cb7e1f7c3d6ff0221e826f2ad8'.

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

21Using target Scala version for migration: 3.7.4

22Migrating project for -source:3.4 using Scala 3.7.4

23----

24Preparing build for 3.7.4

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

26Append: -rewrite,REQUIRE:-source:3.4-migration

27Remove: -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

28----

29Starting build for 3.7.4

30Execute tests: false

31sbt project found:

32No prepare script found for project flink-extended/flink-scala-api

33##################################

34Scala version: 3.7.4

35Targets: org.flinkextended%flink-scala-api-1 org.flinkextended%flink-scala-api-2 org.flinkextended%flink-scala-api-common

36Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[]}

37##################################

38Using extra scalacOptions: -rewrite,REQUIRE:-source:3.4-migration

39Filtering out scalacOptions: -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

40[sbt_options] declare -a sbt_options=()

41[process_args] java_version = '17'

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

43# Executing command line:

44java

45-Dfile.encoding=UTF-8

46-Dcommunitybuild.scala=3.7.4

47-Dcommunitybuild.project.dependencies.add=

48-Xmx7G

49-Xms4G

50-Xss8M

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

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

53-jar

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

55"setCrossScalaVersions 3.7.4"

56"++3.7.4 -v"

57"mapScalacOptions "-rewrite,REQUIRE:-source:3.4-migration,-Wconf:msg=can be rewritten automatically under:s" "-indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e""

58"set every credentials := Nil"

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

60"removeScalacOptionsStartingWith -P:wartremover"

62moduleMappings

63"runBuild 3.7.4 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[]}""" org.flinkextended%flink-scala-api-1 org.flinkextended%flink-scala-api-2 org.flinkextended%flink-scala-api-common"

65[info] [launcher] getting org.scala-sbt sbt 1.11.7 (this may take some time)...

66[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 17.0.8)

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

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

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

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

71[info] Compilation completed in 9.148s.

72[info] done compiling

73[info] loading settings for project root from build.sbt...

74[info] set current project to root (in build file:/build/repo/)

86Execute setCrossScalaVersions: 3.7.4

87OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in scala-api-common/crossScalaVersions

88OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in flink-2-api/crossScalaVersions

89OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in docs/crossScalaVersions

90OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in root/crossScalaVersions

91OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in flink-1-api/crossScalaVersions

92OpenCB::Changing crossVersion 3.3.6 -> 3.7.4 in examples/crossScalaVersions

93[info] set current project to root (in build file:/build/repo/)

94[info] Setting Scala version to 3.7.4 on 6 projects.

95[info] Switching Scala version on:

96[info] examples (3.7.4)

97[info] * root (2.13.16, 3.7.4)

98[info] docs (2.13.16, 3.7.4)

99[info] flink-2-api (2.13.16, 3.7.4)

100[info] scala-api-common (2.13.16, 3.7.4)

101[info] flink-1-api (2.13.16, 3.7.4)

102[info] Excluding projects:

103[info] Reapplying settings...

104[info] set current project to root (in build file:/build/repo/)

105Execute mapScalacOptions: -rewrite,REQUIRE:-source:3.4-migration,-Wconf:msg=can be rewritten automatically under:s -indent,-no-indent,-new-syntax,,-deprecation,-feature,-Xfatal-warnings,-Werror,MATCH:.*-Wconf.*any:e

106[info] Reapplying settings...

107[info] set current project to root (in build file:/build/repo/)

108[info] Defining Global / credentials, credentials and 4 others.

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

110[info] Run `last` for details.

111[info] Reapplying settings...

112[info] set current project to root (in build file:/build/repo/)

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

114[info] Reapplying settings...

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

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

118 Did you mean allExcludeDependencies ?

119 , retry without global scopes

120[info] Reapplying settings...

121[info] set current project to root (in build file:/build/repo/)

122Execute removeScalacOptionsStartingWith: -P:wartremover

123[info] Reapplying settings...

124[info] set current project to root (in build file:/build/repo/)

125[success] Total time: 0 s, completed Jan 8, 2026, 1:40:35 AM

126Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"compile-only","migrationVersions":["3.4"],"sourcePatches":[]}

127Parsed config: Success(ProjectBuildConfig(ProjectsConfig(List(),Map()),CompileOnly,List()))

128Starting build...

129Projects: Set(flink-1-api, flink-2-api, scala-api-common)

130Starting build for ProjectRef(file:/build/repo/,flink-1-api) (flink-scala-api-1)... [0/3]

131OpenCB::Exclude Scala3 specific scalacOption `-rewrite` in Scala 2.12.20 module Global

132OpenCB::Exclude Scala3 specific scalacOption `REQUIRE:-source:3.4-migration` in Scala 2.12.20 module Global

133OpenCB::Filter out '-deprecation', matches setting pattern '^-?-deprecation'

134OpenCB::Filter out '-feature', matches setting pattern '^-?-feature'

135Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

136[info] compiling 70 Scala sources and 3 Java sources to /build/repo/modules/flink-common-api/target/scala-3.7.4/classes ...

137[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/util/ScalaReduceFunction.scala]

138[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/EitherTypeInfo.scala]

139[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/util/ScalaWindowFunction.scala]

140[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/FailFastTypeInfoFactory.scala]

141[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/serializer/CoproductSerializer.scala]

142[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/CaseClassTypeInfo.scala]

143[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/serializer/CaseClassSerializer.scala]

144[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/util/ScalaProcessWindowFunctionWrapper.scala]

145[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/CaseClassComparator.scala]

146[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/util/ClassUtil.scala]

147[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/OptionTypeInfo.scala]

148[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/StatefulFunction.scala]

149[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/typeinfo/OptionTypeComparator.scala]

150[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/function/util/ScalaAllWindowFunction.scala]

151[info] [patched file /build/repo/modules/flink-common-api/src/main/scala-3/org/apache/flinkx/api/TaggedDerivation.scala]

152[info] [patched file /build/repo/modules/flink-common-api/src/main/scala/org/apache/flinkx/api/ClosureCleaner.scala]

153[info] /build/repo/modules/flink-common-api/src/main/java/org/apache/flinkx/api/serializer/ScalaCaseClassSerializerSnapshot.java: Some input files use or override a deprecated API.

154[info] /build/repo/modules/flink-common-api/src/main/java/org/apache/flinkx/api/serializer/ScalaCaseClassSerializerSnapshot.java: Recompile with -Xlint:deprecation for details.

155[info] done compiling

156[info] compiling 19 Scala sources to /build/repo/modules/flink-1-api/target/scala-3.7.4/classes ...

157[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/CoGroupedStreams.scala]

158[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/JoinedStreams.scala]

159[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/KeyedStream.scala]

160[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/ScalaStreamOps.scala]

161[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/WindowedStream.scala]

162[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/AllWindowedStream.scala]

163[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala]

164[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/ConnectedStreams.scala]

165[info] [patched file /build/repo/modules/flink-1-api/src/main/scala/org/apache/flinkx/api/DataStream.scala]

168[info] done compiling

169[info] compiling 16 Scala sources to /build/repo/modules/flink-common-api/target/scala-3.7.4/classes ...

170[info] done compiling

171[info] compiling 2 Scala sources to /build/repo/modules/flink-common-api/target/scala-3.7.4/classes ...

172[info] done compiling

173[info] compiling 9 Scala sources to /build/repo/modules/flink-1-api/target/scala-3.7.4/classes ...

176[info] done compiling

177[info] compiling 8 Scala sources to /build/repo/modules/flink-1-api/target/scala-3.7.4/test-classes ...

178[info] [patched file /build/repo/modules/flink-1-api/src/test/scala/org/apache/flinkx/api/DataStreamTest.scala]

181[info] done compiling

182[info] compiling 1 Scala source to /build/repo/modules/flink-1-api/target/scala-3.7.4/test-classes ...

185[info] done compiling

186Starting build for ProjectRef(file:/build/repo/,flink-2-api) (flink-scala-api-2)... [1/3]

187Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

188[info] compiling 19 Scala sources to /build/repo/modules/flink-2-api/target/scala-3.7.4/classes ...

189[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/StreamExecutionEnvironment.scala]

190[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/JoinedStreams.scala]

191[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/ConnectedStreams.scala]

192[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/DataStream.scala]

193[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/CoGroupedStreams.scala]

194[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/ScalaStreamOps.scala]

195[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/WindowedStream.scala]

196[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/AllWindowedStream.scala]

197[info] [patched file /build/repo/modules/flink-2-api/src/main/scala/org/apache/flinkx/api/KeyedStream.scala]

200[info] done compiling

201[info] compiling 9 Scala sources to /build/repo/modules/flink-2-api/target/scala-3.7.4/classes ...

204[info] done compiling

205[info] compiling 8 Scala sources to /build/repo/modules/flink-2-api/target/scala-3.7.4/test-classes ...

206[info] [patched file /build/repo/modules/flink-2-api/src/test/scala/org/apache/flinkx/api/DataStreamTest.scala]

209[info] done compiling

210[info] compiling 1 Scala source to /build/repo/modules/flink-2-api/target/scala-3.7.4/test-classes ...

211[info] done compiling

212Starting build for ProjectRef(file:/build/repo/,scala-api-common) (flink-scala-api-common)... [2/3]

213Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -rewrite, -Wconf:msg=can be rewritten automatically under:s, -source:3.4-migration

214[info] compiling 19 Scala sources to /build/repo/modules/flink-common-api/target/scala-3.7.4/test-classes ...

215[info] [patched file /build/repo/modules/flink-common-api/src/test/scala/org/apache/flinkx/api/TestUtils.scala]

216[info] [patched file /build/repo/modules/flink-common-api/src/test/scala/org/apache/flinkx/api/SerializerSnapshotTest.scala]

217[info] done compiling

218[info] compiling 2 Scala sources to /build/repo/modules/flink-common-api/target/scala-3.7.4/test-classes ...

219[info] done compiling

221************************

222Build summary:

223[{

224 "module": "flink-scala-api-1",

225 "compile": {"status": "ok", "tookMs": 15022, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

227 "test-compile": {"status": "ok", "tookMs": 12328, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

230 "metadata": {

231 "crossScalaVersions": ["2.13.16", "3.3.6"]

232}

233},{

234 "module": "flink-scala-api-2",

235 "compile": {"status": "ok", "tookMs": 1609, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

237 "test-compile": {"status": "ok", "tookMs": 5880, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

240 "metadata": {

241 "crossScalaVersions": ["2.13.16", "3.3.6"]

242}

243},{

244 "module": "flink-scala-api-common",

245 "compile": {"status": "ok", "tookMs": 56, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

247 "test-compile": {"status": "ok", "tookMs": 18643, "warnings": 0, "errors": 0, "sourceVersion": "3.4-migration"},

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

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

250 "metadata": {

251 "crossScalaVersions": ["2.13.16", "3.3.6"]

252}

253}]

254************************

255[success] Total time: 72 s (0:01:12.0), completed Jan 8, 2026, 1:41:47 AM

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

257Checking patch build.sbt...

258Applied patch project/plugins.sbt cleanly.

259Applied patch build.sbt cleanly.

260Commit migration rewrites

261Switched to a new branch 'opencb/migrate-source-3.4'

262[opencb/migrate-source-3.4 1277337] Apply Scala compiler rewrites using -source:3.4-migration using Scala 3.7.4

263 38 files changed, 233 insertions(+), 233 deletions(-)

264----

265Preparing build for 3.8.0-RC6

266Scala binary version found: 3.8

267Implicitly using source version 3.8

268Scala binary version found: 3.8

269Implicitly using source version 3.8

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

271Append: ,REQUIRE:-source:3.8

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

273----

274Starting build for 3.8.0-RC6

275Execute tests: true

276sbt project found:

277No prepare script found for project flink-extended/flink-scala-api

278##################################

279Scala version: 3.8.0-RC6

280Targets: org.flinkextended%flink-scala-api-1 org.flinkextended%flink-scala-api-2 org.flinkextended%flink-scala-api-common

281Project projectConfig: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[]}

282##################################

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

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

285[sbt_options] declare -a sbt_options=()

286[process_args] java_version = '17'

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

288# Executing command line:

289java

290-Dfile.encoding=UTF-8

291-Dcommunitybuild.scala=3.8.0-RC6

292-Dcommunitybuild.project.dependencies.add=

293-Xmx7G

294-Xms4G

295-Xss8M

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

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

298-jar

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

300"setCrossScalaVersions 3.8.0-RC6"

301"++3.8.0-RC6 -v"

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

303"set every credentials := Nil"

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

305"removeScalacOptionsStartingWith -P:wartremover"

307moduleMappings

308"runBuild 3.8.0-RC6 """{"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[]}""" org.flinkextended%flink-scala-api-1 org.flinkextended%flink-scala-api-2 org.flinkextended%flink-scala-api-common"

310[info] welcome to sbt 1.11.7 (Eclipse Adoptium Java 17.0.8)

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

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

313[info] loading settings for project root from build.sbt...

314[info] set current project to root (in build file:/build/repo/)

326Execute setCrossScalaVersions: 3.8.0-RC6

327OpenCB::Changing crossVersion 3.3.6 -> 3.8.0-RC6 in scala-api-common/crossScalaVersions

328OpenCB::Changing crossVersion 3.3.6 -> 3.8.0-RC6 in flink-2-api/crossScalaVersions

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

330OpenCB::Changing crossVersion 3.3.6 -> 3.8.0-RC6 in root/crossScalaVersions

331OpenCB::Changing crossVersion 3.3.6 -> 3.8.0-RC6 in flink-1-api/crossScalaVersions

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

333[info] set current project to root (in build file:/build/repo/)

334[info] Setting Scala version to 3.8.0-RC6 on 6 projects.

335[info] Switching Scala version on:

336[info] examples (3.8.0-RC6)

337[info] * root (2.13.16, 3.8.0-RC6)

338[info] docs (2.13.16, 3.8.0-RC6)

339[info] flink-2-api (2.13.16, 3.8.0-RC6)

340[info] scala-api-common (2.13.16, 3.8.0-RC6)

341[info] flink-1-api (2.13.16, 3.8.0-RC6)

342[info] Excluding projects:

343[info] Reapplying settings...

344[info] set current project to root (in build file:/build/repo/)

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

346[info] Reapplying settings...

347[info] set current project to root (in build file:/build/repo/)

348[info] Defining Global / credentials, credentials and 4 others.

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

350[info] Run `last` for details.

351[info] Reapplying settings...

352[info] set current project to root (in build file:/build/repo/)

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

354[info] Reapplying settings...

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

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

358 Did you mean allExcludeDependencies ?

359 , retry without global scopes

360[info] Reapplying settings...

361[info] set current project to root (in build file:/build/repo/)

362Execute removeScalacOptionsStartingWith: -P:wartremover

363[info] Reapplying settings...

364[info] set current project to root (in build file:/build/repo/)

365[success] Total time: 0 s, completed Jan 8, 2026, 1:41:58 AM

366Build config: {"projects":{"exclude":[],"overrides":{}},"java":{"version":"17"},"sbt":{"commands":[],"options":[]},"mill":{"options":[]},"tests":"full","migrationVersions":["3.4"],"sourcePatches":[]}

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

368Starting build...

369Projects: Set(flink-1-api, flink-2-api, scala-api-common)

370Starting build for ProjectRef(file:/build/repo/,flink-1-api) (flink-scala-api-1)... [0/3]

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

372OpenCB::Filter out '-deprecation', matches setting pattern '^-?-deprecation'

373OpenCB::Filter out '-feature', matches setting pattern '^-?-feature'

374Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

375[info] compiling 70 Scala sources and 3 Java sources to /build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/classes ...

376[info] /build/repo/modules/flink-common-api/src/main/java/org/apache/flinkx/api/serializer/ScalaCaseClassSerializerSnapshot.java: Some input files use or override a deprecated API.

377[info] /build/repo/modules/flink-common-api/src/main/java/org/apache/flinkx/api/serializer/ScalaCaseClassSerializerSnapshot.java: Recompile with -Xlint:deprecation for details.

378[info] done compiling

379[info] compiling 19 Scala sources to /build/repo/modules/flink-1-api/target/scala-3.8.0-RC6/classes ...

382[info] done compiling

383[info] compiling 8 Scala sources to /build/repo/modules/flink-1-api/target/scala-3.8.0-RC6/test-classes ...

386[info] done compiling

387[info] CoGroupedStreamsTest:

3882026-01-08 00:42:29.741+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

3892026-01-08 00:42:29.856+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

3902026-01-08 00:42:30.230+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

3912026-01-08 00:42:30.313+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

3922026-01-08 00:42:30.588+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

393[info] - should set allowed lateness

3942026-01-08 00:42:30.747+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

395[info] StreamExecutionEnvironmentTest:

3962026-01-08 00:42:30.910+0000 INFO flink-pekko.actor.default-dispatcher-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

3972026-01-08 00:42:30.951+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

3982026-01-08 00:42:31.021+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

3992026-01-08 00:42:31.049+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4002026-01-08 00:42:31.066+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

401[info] - should create a stream from a source

402[info] - should create a stream from a sequence

403[info] From Flink 1.19, TypeInformation.of(Class)

404[info] - should fail-fast trying to resolve Scala type

4052026-01-08 00:42:31.105+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

406[info] AsyncDataStreamTest:

4072026-01-08 00:42:31.180+0000 INFO flink-pekko.actor.default-dispatcher-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4082026-01-08 00:42:31.196+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4092026-01-08 00:42:31.226+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4102026-01-08 00:42:31.273+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4112026-01-08 00:42:31.287+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

4122026-01-08 00:42:31.965+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4132026-01-08 00:42:32.077+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4142026-01-08 00:42:32.111+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

415[info] - should apply rich async function to the stream in ordered manner

4162026-01-08 00:42:33.338+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4172026-01-08 00:42:33.452+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4182026-01-08 00:42:33.485+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

419[info] - should apply rich async function to the stream in ordered manner with retry policy

4202026-01-08 00:42:34.245+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4212026-01-08 00:42:34.339+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4222026-01-08 00:42:34.369+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

423[info] - should apply rich async function to the stream in unordered manner

4242026-01-08 00:42:35.079+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4252026-01-08 00:42:35.184+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4262026-01-08 00:42:35.215+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

427[info] - should apply rich async function to the stream in unordered manner with retry policy

4282026-01-08 00:42:35.903+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4292026-01-08 00:42:35.982+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4302026-01-08 00:42:36.014+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

431[info] - should apply anon async function to the stream in ordered manner

4322026-01-08 00:42:36.741+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4332026-01-08 00:42:36.826+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4342026-01-08 00:42:36.852+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

435[info] - should apply anon async function to the stream in ordered manner with retry policy

4362026-01-08 00:42:37.487+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4372026-01-08 00:42:37.572+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4382026-01-08 00:42:37.598+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

439[info] - should apply anon async function to the stream in unordered manner

4402026-01-08 00:42:38.258+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4412026-01-08 00:42:38.348+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4422026-01-08 00:42:38.377+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

443[info] - should apply anon async function to the stream in unordered manner with retry policy

4442026-01-08 00:42:38.533+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

445[info] DataStreamTest:

4462026-01-08 00:42:38.610+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4472026-01-08 00:42:38.630+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4482026-01-08 00:42:38.651+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4492026-01-08 00:42:38.695+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4502026-01-08 00:42:38.704+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

451[info] - should set operator names

452[info] - should set operator descriptions

453[info] - should set partitions

454[info] - should set parallelism

455[info] - should fail parallelism after partitioning

456[info] - should keep type information

457[info] - should translate keyed stream process function to operator

458[info] - should translate keyed stream keyed process function to operator

459[info] - should translate stream process function to operator

460[info] - should create stream graph from operators

461[info] - should assign partitioner

462[info] - should set iterations

463[info] - should pass created type information

4642026-01-08 00:42:39.393+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

465[info] JoinedStreamsTest:

4662026-01-08 00:42:39.443+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4672026-01-08 00:42:39.455+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4682026-01-08 00:42:39.475+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4692026-01-08 00:42:39.519+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4702026-01-08 00:42:39.526+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

471[info] - should set allowed lateness

4722026-01-08 00:42:39.536+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

473[info] ExampleTest:

4742026-01-08 00:42:39.590+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4752026-01-08 00:42:39.600+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4762026-01-08 00:42:39.619+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4772026-01-08 00:42:39.627+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4782026-01-08 00:42:39.635+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

4792026-01-08 00:42:40.142+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4802026-01-08 00:42:40.224+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4812026-01-08 00:42:40.254+0000 INFO pool-1-thread-1-ScalaTest-running-ExampleTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

482[info] - should serialize elements with type mappers across operators

4832026-01-08 00:42:40.443+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

484Starting build for ProjectRef(file:/build/repo/,flink-2-api) (flink-scala-api-2)... [1/3]

485Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

486[info] compiling 19 Scala sources to /build/repo/modules/flink-2-api/target/scala-3.8.0-RC6/classes ...

489[info] done compiling

490[info] compiling 8 Scala sources to /build/repo/modules/flink-2-api/target/scala-3.8.0-RC6/test-classes ...

493[info] done compiling

494[info] CoGroupedStreamsTest:

4952026-01-08 00:42:50.148+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4962026-01-08 00:42:50.256+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

4972026-01-08 00:42:50.616+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4982026-01-08 00:42:50.714+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

4992026-01-08 00:42:50.973+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

500[info] - should set allowed lateness

5012026-01-08 00:42:51.122+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

502[info] StreamExecutionEnvironmentTest:

5032026-01-08 00:42:51.267+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5042026-01-08 00:42:51.285+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5052026-01-08 00:42:51.315+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5062026-01-08 00:42:51.331+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5072026-01-08 00:42:51.348+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

508[info] - should create a stream from a source

509[info] - should create a stream from a sequence

510[info] TypeInformation.of(Class)

511[info] - should fail-fast trying to resolve Scala type

5122026-01-08 00:42:51.384+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

513[info] AsyncDataStreamTest:

5142026-01-08 00:42:51.449+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5152026-01-08 00:42:51.464+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5162026-01-08 00:42:51.522+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5172026-01-08 00:42:51.565+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5182026-01-08 00:42:51.577+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

5192026-01-08 00:42:52.250+0000 INFO flink-pekko.actor.default-dispatcher-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5202026-01-08 00:42:52.364+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5212026-01-08 00:42:52.404+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

522[info] - should apply rich async function to the stream in ordered manner

5232026-01-08 00:42:53.538+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5242026-01-08 00:42:53.624+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5252026-01-08 00:42:53.656+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

526[info] - should apply rich async function to the stream in ordered manner with retry policy

5272026-01-08 00:42:54.366+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5282026-01-08 00:42:54.447+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5292026-01-08 00:42:54.475+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

530[info] - should apply rich async function to the stream in unordered manner

5312026-01-08 00:42:55.146+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5322026-01-08 00:42:55.231+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5332026-01-08 00:42:55.258+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

534[info] - should apply rich async function to the stream in unordered manner with retry policy

5352026-01-08 00:42:55.929+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5362026-01-08 00:42:56.011+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5372026-01-08 00:42:56.036+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

538[info] - should apply anon async function to the stream in ordered manner

5392026-01-08 00:42:56.716+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5402026-01-08 00:42:56.795+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5412026-01-08 00:42:56.821+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

542[info] - should apply anon async function to the stream in ordered manner with retry policy

5432026-01-08 00:42:57.462+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5442026-01-08 00:42:57.546+0000 INFO flink-metrics-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5452026-01-08 00:42:57.575+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

546[info] - should apply anon async function to the stream in unordered manner

5472026-01-08 00:42:58.228+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5482026-01-08 00:42:58.316+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5492026-01-08 00:42:58.346+0000 INFO pool-1-thread-1-ScalaTest-running-AsyncDataStreamTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

550[info] - should apply anon async function to the stream in unordered manner with retry policy

5512026-01-08 00:42:58.486+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

552[info] DataStreamTest:

5532026-01-08 00:42:58.547+0000 INFO flink-pekko.actor.default-dispatcher-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5542026-01-08 00:42:58.562+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5552026-01-08 00:42:58.582+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5562026-01-08 00:42:58.626+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5572026-01-08 00:42:58.635+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

558[info] - should set operator names

559[info] - should set operator descriptions

560[info] - should set partitions

561[info] - should set parallelism

562[info] - should fail parallelism after partitioning

563[info] - should keep type information

564[info] - should translate keyed stream process function to operator

565[info] - should translate keyed stream keyed process function to operator

566[info] - should translate stream process function to operator

567[info] - should create stream graph from operators

568[info] - should assign partitioner

5692026-01-08 00:42:59.193+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

570[info] JoinedStreamsTest:

5712026-01-08 00:42:59.252+0000 INFO flink-pekko.actor.default-dispatcher-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5722026-01-08 00:42:59.268+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5732026-01-08 00:42:59.287+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5742026-01-08 00:42:59.322+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5752026-01-08 00:42:59.331+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

576[info] - should set allowed lateness

5772026-01-08 00:42:59.340+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

578[info] ExampleTest:

5792026-01-08 00:42:59.382+0000 INFO flink-pekko.actor.default-dispatcher-6 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5802026-01-08 00:42:59.393+0000 INFO flink-metrics-5 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5812026-01-08 00:42:59.438+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5822026-01-08 00:42:59.476+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

5832026-01-08 00:42:59.483+0000 INFO pool-1-thread-1 o.a.f.c.Configuration Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'

5842026-01-08 00:43:00.011+0000 INFO flink-pekko.actor.default-dispatcher-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5852026-01-08 00:43:00.092+0000 INFO flink-metrics-4 o.a.p.e.s.Slf4jLogger Slf4jLogger started

5862026-01-08 00:43:00.116+0000 INFO pool-1-thread-1-ScalaTest-running-ExampleTest o.a.f.c.Configuration Config uses fallback configuration key 'pekko.ask.timeout' instead of key 'taskmanager.slot.timeout'

587[info] - should serialize elements with type mappers across operators

5882026-01-08 00:43:00.292+0000 INFO pool-1-thread-1 o.a.f.t.u.MiniClusterWithClientResource Finalization triggered: Cluster shutdown is going to be initiated.

589Starting build for ProjectRef(file:/build/repo/,scala-api-common) (flink-scala-api-common)... [2/3]

590Compile scalacOptions: -language:higherKinds, -language:implicitConversions, -Xmax-inlines, 128, -Wconf:msg=can be rewritten automatically under:s, -source:3.8

591[info] compiling 19 Scala sources to /build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/test-classes ...

592[info] done compiling

593[info] CollectionSerializerSnapshotTest:

59401:43:25,719 |-INFO in ch.qos.logback.classic.LoggerContext[default] - This is logback-classic version 1.5.19

59501:43:25,720 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - No custom configurators were discovered as a service.

59601:43:25,720 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - Trying to configure with ch.qos.logback.classic.joran.SerializedModelConfigurator

59701:43:25,720 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - Constructed configurator of type class ch.qos.logback.classic.joran.SerializedModelConfigurator

59801:43:25,723 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.scmo]

59901:43:25,723 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.scmo]

60001:43:25,729 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - ch.qos.logback.classic.joran.SerializedModelConfigurator.configure() call lasted 3 milliseconds. ExecutionStatus=INVOKE_NEXT_IF_ANY

60101:43:25,729 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - Trying to configure with ch.qos.logback.classic.util.DefaultJoranConfigurator

60201:43:25,729 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - Constructed configurator of type class ch.qos.logback.classic.util.DefaultJoranConfigurator

60301:43:25,729 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback-test.xml]

60401:43:25,730 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback.xml] at [file:/build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/test-classes/logback.xml]

60501:43:25,730 |-WARN in ch.qos.logback.classic.util.DefaultJoranConfigurator@3604af2b - Resource [logback.xml] occurs multiple times on the classpath.

60601:43:25,731 |-WARN in ch.qos.logback.classic.util.DefaultJoranConfigurator@3604af2b - Resource [logback.xml] occurs at [file:/build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/test-classes/logback.xml]

60701:43:25,731 |-WARN in ch.qos.logback.classic.util.DefaultJoranConfigurator@3604af2b - Resource [logback.xml] occurs at [file:/build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/classes/logback.xml]

60801:43:25,802 |-INFO in ch.qos.logback.classic.model.processor.LoggerContextListenerModelHandler - Adding LoggerContextListener of type [ch.qos.logback.classic.jul.LevelChangePropagator] to the object stack

60901:43:25,812 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@46303fb3 - Propagating DEBUG level on Logger[ROOT] onto the JUL framework

61001:43:25,813 |-INFO in ch.qos.logback.classic.model.processor.LoggerContextListenerModelHandler - Starting LoggerContextListener

61101:43:25,816 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Registering a new ReconfigureOnChangeTask ReconfigureOnChangeTask(born:1767833005814)

61201:43:25,816 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Will scan for changes in [ch.qos.logback.core.joran.spi.ConfigurationWatchList@5af602f1]

61301:43:25,816 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Setting ReconfigureOnChangeTask scanning period to 1 minutes

61401:43:25,819 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - Main configuration file URL: file:/build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/test-classes/logback.xml

61501:43:25,820 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - FileWatchList= {/build/repo/modules/flink-common-api/target/scala-3.8.0-RC6/test-classes/logback.xml}

61601:43:25,820 |-INFO in ch.qos.logback.classic.model.processor.ConfigurationModelHandlerFull - URLWatchList= {}

61701:43:25,821 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [STDOUT]

61801:43:25,821 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]

61901:43:25,824 |-INFO in ch.qos.logback.core.model.processor.ImplicitModelHandler - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property

62001:43:25,852 |-INFO in ch.qos.logback.classic.pattern.DateConverter@35062653 - Setting zoneId to "UTC"

62101:43:25,854 |-INFO in ch.qos.logback.core.ConsoleAppender[STDOUT] - NOTE: Writing to the console can be slow. Try to avoid logging to the

62201:43:25,854 |-INFO in ch.qos.logback.core.ConsoleAppender[STDOUT] - console in production environments, especially in high volume systems.

62301:43:25,854 |-INFO in ch.qos.logback.core.ConsoleAppender[STDOUT] - See also https://logback.qos.ch/codes.html#slowConsole

62401:43:25,854 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - Processing appender named [ASYNCSTDOUT]

62501:43:25,854 |-INFO in ch.qos.logback.core.model.processor.AppenderModelHandler - About to instantiate appender of type [ch.qos.logback.classic.AsyncAppender]

62601:43:25,855 |-INFO in ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [STDOUT] to ch.qos.logback.classic.AsyncAppender[ASYNCSTDOUT]

62701:43:25,856 |-INFO in ch.qos.logback.classic.AsyncAppender[ASYNCSTDOUT] - Attaching appender named [STDOUT] to AsyncAppender.

62801:43:25,856 |-INFO in ch.qos.logback.classic.AsyncAppender[ASYNCSTDOUT] - Setting discardingThreshold to 51

62901:43:25,856 |-INFO in ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [org.apache.flink.runtime] to OFF

63001:43:25,856 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@46303fb3 - Propagating OFF level on Logger[org.apache.flink.runtime] onto the JUL framework

63101:43:25,857 |-INFO in ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [org.apache.flink.streaming.runtime] to OFF

63201:43:25,857 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@46303fb3 - Propagating OFF level on Logger[org.apache.flink.streaming.runtime] onto the JUL framework

63301:43:25,857 |-INFO in ch.qos.logback.classic.model.processor.RootLoggerModelHandler - Setting level of ROOT logger to INFO

63401:43:25,857 |-INFO in ch.qos.logback.classic.jul.LevelChangePropagator@46303fb3 - Propagating INFO level on Logger[ROOT] onto the JUL framework

63501:43:25,857 |-INFO in ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [ASYNCSTDOUT] to Logger[ROOT]

63601:43:25,857 |-INFO in ch.qos.logback.core.model.processor.DefaultProcessor@638c26d8 - End of configuration.

63701:43:25,857 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@7062a075 - Registering current configuration as safe fallback point

63801:43:25,857 |-INFO in ch.qos.logback.classic.util.ContextInitializer@2c4f4261 - ch.qos.logback.classic.util.DefaultJoranConfigurator.configure() call lasted 128 milliseconds. ExecutionStatus=DO_NOT_INVOKE_NEXT_IF_ANY

640[info] - should serialize then deserialize

641[info] ClassUtilTest:

642[info] - should return true when all the fields are val

643[info] - should return false when one of the fields is a var

644[info] - should return true when all the fields are private val

645[info] - should return false when one of the fields is a private var

646[info] - should return true when the field is a disrupted private val

647[info] - should return false when the field is a disrupted private var

648[info] - should return true when the fields are in parent classes

649[info] - should return false when one of the fields which is not in parent classes is a var

650[info] - should return true when the field doesn't exist

651[info] GenericCaseClassScala3Test:

652[info] Both TypeInformation of Animal Basket

653[info] - should have their respective TypeInformation of Animal

654[info] Nested generics

655[info] - should be resolved correctly

656[info] - should work with multiple type parameters

657[info] AnyTest:

658[info] - should serialize concrete class

659[info] - should serialize ADT

660[info] - should serialize NEL

661[info] - should serialize nested nel

662[info] ArraySerializerTest:

663[info] - should copy to new array with same immutable elements

664[info] - should copy to new array with a copy of mutable elements

665[info] - should return itself when duplicate an immutable serializer

666[info] - should duplicate itself when the serializer is mutable

667[info] SerializerTest:

668[info] - should derive serializer for simple class

669[info] - should derive serializer for java classes

670[info] - should derive serializer for java.time classes

671[info] - should derive nested classes

672[info] - should derive for ADTs

673[info] - should derive for ADTs with case objects

674[info] - should derive for deeply nested classes

675[info] - should derive for deeply nested adts

676[info] - should derive for nested ADTs

677[info] - should derive for generic ADTs

678[info] - should derive seq

679[info] - should derive list of ADT

680[info] - should derive list

681[info] - should derive nested list

682[info] - should derive seq of seq

683[info] - should derive generic type bounded classes

684[info] - should return the same TypeSerializer instance with case classes

685[info] - should be serializable in case of annotations on classes

686[info] - should be serializable in case of annotations on subtypes

687[info] - should serialize Option

688[info] - should serialize Either

689[info] - should serialize nested list of ADT

690[info] - should derive multiple instances of generic class

691[info] - should serialize nil

692[info] - should serialize unit

693[info] - should serialize triple-nested case clases

694[info] - should serialize classes with type mapper

695[info] - should serialize bigint

696[info] - should serialize bigdec

697[info] - should serialize uuid

698[info] - should serialize case class with private field

699[info] - should serialize a case class overriding a field

700[info] - should serialize a null case class

701[info] - should serialize a case class with nullable field

702[info] - should serialize a case class with a nullable field of a case class with no arity

703[info] - should serialize nullable fields

704[info] - should serialize a case class with a nullable field of a fixed size case class

705[info] - should serialize ZoneId

706[info] - should serialize ZoneOffset

707[info] - should serialize OffsetDateTime

708[info] - should serialize ZonedDateTime

709[info] SchemaEvolutionTest:

710[info] - should serialize click with old serializer and deserialize it with new serializer

711[info] - should decode click when we added view

712[info] SerializerSnapshotTest:

713[info] - should roundtrip product serializer snapshot

714[info] - should roundtrip coproduct serializer snapshot

715[info] - should roundtrip coproduct serializer snapshot with singletons

716[info] - should roundtrip serializer snapshot with list of primitives

717[info] - should roundtrip serializer snapshot with set as array of primitives

718[info] - should do array ser snapshot

719[info] - should do map ser snapshot

720[info] - should do list ser snapshot

721[info] - should do map ser snapshot adt

722[info] - should be compatible after snapshot deserialization in different classloader

723[info] - should deserialize old serialization with the new serializer snapshot

724[info] - should serialize and deserialize with the new snapshot

725[info] - should serialize and deserialize case class with null and default

726[info] CoproductSerializerSnapshotTest:

727[info] - should serialize then deserialize

728[info] MappedSerializerSnapshotTest:

729[info] - should serialize then deserialize

730[info] Scala3EnumTest:

731[info] - should derive type information for a Scala 3 enum

732[info] MappedTypeInfoTest:

733[info] - should derive TI for non-serializable classes

734[info] CaseClassSerializerTest:

735[info] isImmutableType

736[info] - should be true when parameters are immutable

737[info] - should be false when one parameter is mutable

738[info] - should be false when the content of one parameter is mutable

739[info] isImmutableSerializer

740[info] - should be true when sub-serializers are immutable

741[info] - should be false when one sub-serializer is mutable

742[info] copy

743[info] - should return the same case class when immutable

744[info] - should return null when the given case class is null

745[info] - should copy the case class when mutable

746[info] - should copy the case class and its content when the content of one parameter is mutable

747[info] - should copy the case class when mutable but not its immutable content

748[info] - should copy the serialized stream

749[info] duplicate

750[info] - should return itself when the serializer is immutable

751[info] - should return a new instance of itself when the serializer is mutable

752[info] CatsTest:

753[info] - should derive for NEL[String]

754[info] - should derive for NEL[Int]

755[info] TypeInfoTest:

756[info] - should derive simple classes

757[info] - should derive parameterized classes

758[info] - should derive lists

759[info] - should derive arrays

760[info] - should derive maps

761[info] - should derive ADT

762[info] MapSerializerSnapshotTest:

763[info] - should serialize the old data and deserialize them to the new data

764[info] ProcessFunctionTest:

765[info] ProcessFunction

766[info] - should return same values unchanged

767[info] CoproductSerializerTest:

768[info] isImmutableType

769[info] - should be true when all subtypes of the sealed trait are immutable

770[info] - should be false when one subtype of the sealed trait is mutable

771[info] isImmutableSerializer

772[info] - should be true when all sub-serializers of the sealed trait are immutable

773[info] - should be false when one sub-serializer of the sealed trait is mutable

774[info] copy

775[info] - should return null when the given object is null

776[info] - should return the same instance when the data is immutable

777[info] - should copy the instance when the data is mutable

778[info] - should return the same instance when immutable even if some other subtypes of the sealed trait are mutable

779[info] duplicate

780[info] - should return itself when the serializer is immutable

781[info] - should return a new instance of itself when the serializer is mutable

783************************

784Build summary:

785[{

786 "module": "flink-scala-api-1",

787 "compile": {"status": "ok", "tookMs": 15587, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

790 "test": {"status": "ok", "tookMs": 12877, "passed": 27, "failed": 0, "ignored": 0, "skipped": 0, "total": 27, "byFramework": [{"framework": "unknown", "stats": {"passed": 27, "failed": 0, "ignored": 0, "skipped": 0, "total": 27}}]},

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

792 "metadata": {

793 "crossScalaVersions": ["2.13.16", "3.3.6"]

794}

795},{

796 "module": "flink-scala-api-2",

797 "compile": {"status": "ok", "tookMs": 1910, "warnings": 0, "errors": 0, "sourceVersion": "3.8"},

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

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

800 "test": {"status": "ok", "tookMs": 12212, "passed": 25, "failed": 0, "ignored": 0, "skipped": 0, "total": 25, "byFramework": [{"framework": "unknown", "stats": {"passed": 25, "failed": 0, "ignored": 0, "skipped": 0, "total": 25}}]},

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

802 "metadata": {

803 "crossScalaVersions": ["2.13.16", "3.3.6"]

804}

805},{

806 "module": "flink-scala-api-common",

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

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

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

810 "test": {"status": "ok", "tookMs": 2282, "passed": 114, "failed": 0, "ignored": 0, "skipped": 0, "total": 114, "byFramework": [{"framework": "unknown", "stats": {"passed": 114, "failed": 0, "ignored": 0, "skipped": 0, "total": 114}}]},

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

812 "metadata": {

813 "crossScalaVersions": ["2.13.16", "3.3.6"]

814}

815}]

816************************

817[success] Total time: 89 s (0:01:29.0), completed Jan 8, 2026, 1:43:27 AM

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

819Checking patch build.sbt...

820Applied patch project/plugins.sbt cleanly.

821Applied patch build.sbt cleanly.