Re: Setting job/task manager memory management in kubernetes

2020-08-26 Thread Alexey Trenikhun
AM To: user@flink.apache.org Subject: Setting job/task manager memory management in kubernetes Hello, I am trying to set the heap size of job and task manager when deploying the job in kubernetes. I have set the jobmanager.heap.size and taskmanager.heap.size. However, the custom values are not

Re: Setting job/task manager memory management in kubernetes

2020-08-24 Thread Yangze Guo
Hi, You need to define them in "flink-configuration-configmap.yaml". Please also make sure you've created the config map by executing "kubectl create -f flink-configuration-configmap.yaml". [1] https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/kubernetes.html Best, Yang

Re: Setting job/task manager memory management in kubernetes

2020-08-24 Thread Yangze Guo
Hi, Sakshi Could you provide more information about: - What is the Flink version you are using? "taskmanager.heap.size" is deprecated since 1.10[1]. - How do you deploy the cluster? In the approach of native k8s[2] or the standalone k8s[3]? [1] https://ci.apache.org/projects/flink/flink-docs-rel

Setting job/task manager memory management in kubernetes

2020-08-24 Thread Sakshi Bansal
Hello, I am trying to set the heap size of job and task manager when deploying the job in kubernetes. I have set the jobmanager.heap.size and taskmanager.heap.size. However, the custom values are not being used and it is creating its own values and starting the job. How can I set custom values? -