Skip to content

Commit add6df8

Browse files
committed
Change memory allocation again
1 parent 3e76ff5 commit add6df8

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

.test-infra/dataproc/flink_cluster.sh

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,10 @@ FLINK_LOCAL_PORT=8081
6868
# By default each taskmanager has one slot - use that value to avoid sharing SDK Harness by multiple tasks.
6969
FLINK_TASKMANAGER_SLOTS="${FLINK_TASKMANAGER_SLOTS:=1}"
7070

71-
# Crucial config for Fn API gRPC buffer stability and memory allocation
71+
# Config for Fn API gRPC buffer stability and memory allocation
7272
FLINK_PROPS="flink:taskmanager.memory.task.off-heap.size=256m"
73-
FLINK_PROPS+=",flink:taskmanager.memory.process.size=1728m"
73+
FLINK_PROPS+=",flink:taskmanager.memory.process.size=2048m"
74+
FLINK_PROPS+=",flink:taskmanager.memory.managed.fraction=0.1"
7475
FLINK_PROPS+=",flink:jobmanager.memory.process.size=1600m"
7576
FLINK_PROPS+=",flink:taskmanager.numberOfTaskSlots=${FLINK_TASKMANAGER_SLOTS}"
7677

0 commit comments

Comments
 (0)