Flink StateFun应用是否可以运行在Flink会话集群上
Flink StateFun 会话集群部署支持说明
核心结论
当前3.x及更高版本的Flink StateFun仍然支持在已有的Flink会话集群上运行,官方新版文档移除相关描述仅为部署类内容的归类调整,并未下线该能力。
底层逻辑说明
StateFun本质是基于Flink标准运行时实现的上层框架,编译打包后就是普通的Flink作业Jar包,只要满足版本兼容要求,就可以和其他常规Flink作业一样提交到会话集群执行,不需要对集群做任何专属改造。
操作注意事项
- 打包StateFun应用时需要排除Flink核心依赖,避免和会话集群已有的依赖产生冲突
- 提交命令和普通Flink作业完全一致,示例:
flink run -s <可选的savepoint路径> <你的StateFun应用Jar包路径> - 如果使用远程模块部署模式,仅需要在提交命令中额外指定模块配置文件的路径即可
- 必须保证会话集群的Flink大版本和StateFun依赖的Flink版本完全匹配,例如StateFun 3.2对应Flink 1.15,不能跨大版本部署
- 集群的高可用、权限控制、资源配额等配置的适配规则和常规Flink作业完全一致,无需做StateFun专属调整
内容的提问来源于stack exchange,提问作者Neeraj Laad
相关产品推荐
相关产品推荐

