【Flink】Windows环境部署Flink 1.10版本问题解决

最近开始重拾大数据的工作,接手实时计算。计划按照官网的手册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 内存模型详解

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容