On 17 Jun 2015, at 10:10, Sebastian <ssc.o...@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.
