Skip to content

Commit bcad9aa

Browse files
committed
bump metaspace for jobmanager
1 parent b5b9f85 commit bcad9aa

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

engine/flink/test-utils/src/main/scala/pl/touk/nussknacker/engine/flink/test/docker/WithFlinkContainers.scala

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,11 @@ trait WithFlinkContainers extends WithDockerContainers { self: Suite with Strict
3838
command = "jobmanager" :: Nil,
3939
exposedPorts = FlinkJobManagerRestPort :: Nil,
4040
env = Map(
41-
"SAVEPOINT_DIR_NAME" -> savepointDir.getFileName.toString,
42-
"FLINK_PROPERTIES" -> s"state.savepoints.dir: ${savepointDir.toFile.toURI.toString}",
41+
"SAVEPOINT_DIR_NAME" -> savepointDir.getFileName.toString,
42+
// Nu requires a little bit more metaspace than Flink default allocate based on process size
43+
"FLINK_PROPERTIES" ->
44+
s"""jobmanager.memory.jvm-metaspace.size: 400m
45+
|state.savepoints.dir: ${savepointDir.toFile.toURI.toString}""".stripMargin,
4346
"TASK_MANAGER_NUMBER_OF_TASK_SLOTS" -> taskManagerSlotCount.toString
4447
),
4548
waitStrategy = Some(new LogMessageWaitStrategy().withRegEx(".*Recover all persisted job graphs.*"))

0 commit comments

Comments
 (0)