安装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停止。