Flink

共收录文章 1

安装Flink

Flink安装需先配置Java 8或11环境,下载1.18.1版本并解压。核心配置在flink-conf.yaml中:修改rest端口为8111、绑定IP为0.0.0.0以支持外部Web UI访问;开启Checkpointing,设置间隔3s;配置任务槽数(建议与CPU核数一致)、state存储类型(hashmap)及目录,保留最近10个Checkpoint;调整内存,TaskManager和JobManager的Flink总内存分别设为8192m和4096m,元空间各512m;修改pekko.ask.timeout为120s避免超时,并调整bin/config.sh中PID存储目录防止进程清理导致无法停止集群。最后通过start-cluster.sh启动集群,提交示例作业测试,stop-cluster.sh停止。

1
0
195

欢迎来到木因博客

37 文章数
16 分类数
34 评论数
27标签数
最近评论
柳意梧情

柳意梧情


测试评论自动刷新

柳意梧情

柳意梧情


评论测试

柳意梧情

柳意梧情


测试