目前Flink on Kubernetes的大feature已经开发完成,包括native Kubernetes[1](session mode and application mode)、 Kubernetes HA[2]、pod template[3]
1.12版本也引入很多稳定性相关的提升,包括Job任务结束后清理HA信息、ClusterEntrypoint优化避免ConfigMap残留等, 已经达到生产可用的标准。 但是,我相信还是有很多需要打磨的细节,例如:当使用LoadBalancer时返回的结果可能是一个不正确的值,需要梳理 Fabric8FlinkKubeClient#getRestEndpoint的逻辑等,可以通过JIRA的过滤[4]拿到K8s模块相关ticket,挑选感兴趣的开始做 当时你在测试、使用的过程中有任何疑问欢迎在社区的ML里讨论,发现bug开JIRA来跟踪 [1]. https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/ [2]. https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/ha/kubernetes_ha/ [3]. https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/native_kubernetes/#pod-template [4]. https://issues.apache.org/jira/browse/FLINK-23478?jql=project%20%3D%20FLINK%20AND%20resolution%20%3D%20Unresolved%20AND%20component%20%3D%20%22Deployment%20%2F%20Kubernetes%22 laohu <[email protected]> 于2021年7月23日周五 下午5:03写道: > 大家好! > > 请问下flink on kubernetes 开发计划。是否可以参与。 > > >
