flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: Memory in local setting
Date Wed, 17 Jun 2015 09:58:21 GMT

On 17 Jun 2015, at 10:10, Sebastian <ssc.open@googlemail.com> wrote:

> Hi Ufuk,
> 
> Can I configure this when running locally in the IDE or do I have to install Flink for
that?

Yes.

org.apache.flink.configuration.Configuration conf = new Configuration();
conf.setDouble(ConfigConstants.TASK_MANAGER_MEMORY_FRACTION_KEY, 0.7);

LocalEnvironment env = LocalEnvironment.createLocalEnvironment(conf);


You can check the size of size of Flink's managed memory in the logs of the task manager:

11:56:28,061 INFO  org.apache.flink.runtime.taskmanager.TaskManager              - Using 1227
MB for Flink managed memory.
Mime
View raw message