【Flink】Windows环境部署Flink 1.10版本问题
2020-02-26 本文已影响0人
PowerMe
最近开始重拾大数据的工作,接手实时计算。计划按照官网的手册Flink_on_Windows
在Windows环境部署Flink 1.10版本,发现TaskManager启动失败,看日志主要是几个内存参数没有配置导致的,简单记录一下。
直接通过start-cluster.bat启动会拉起JobManager和TaskManager,如果下列参数不配置的话,TaskManager进程会退出,日志显示相关的参数没有配置,在conf/flink-conf.yaml中添加下面的配置,重新启动即可:
taskmanager.cpu.cores: 2
taskmanager.memory.task.heap.size: 512m
taskmanager.memory.managed.size: 512m
taskmanager.memory.network.min: 64m
taskmanager.memory.network.max: 64m
参数可以根据自己的需要设置。
关于Flink 内存模型,这位同学做了很好的分享:Flink 内存模型详解