库伯内特斯的Flink。如何将提交作业步骤添加到jobmanager flink docker？
我使用Flink搭配K8s。一切正常，但我必须在jobmanager启动时手动提交jar。
我认为我们可以扩展flink的形象，并添加提交作业的后期操作。所以jobmanager将是一对一的flink工作。我想这是https://www.youtube.com/watch?v=w721NI-mtAA公司
在这种情况下，如果JM关闭，K8s将启动新的pod并重新提交作业。
我没说错吧？
有没有人对Flink有这样的docker变化？
共有1个答案
我解决了这个问题。
我扩展了flink Docker并添加了一些“flink run”。jar“”步到它。
它工作得很好
https://github.com/Aleksandr-Filichkin/flink-k8s
-
我正在尝试在Kubernetes集群（Azure AKS）中部署Flink作业。作业群集在启动后立即中止，但任务管理器运行正常。 docker镜像创建成功，没有任何异常。我可以运行docker镜像，也可以SSHdocker镜像。 我已经按照以下链接中提到的步骤： https://github.com/apache/flink/tree/release-1.9/flink-container/kub
-
我是Kubernetes的新手，他们的概念我不太清楚：云提供商。 我已经使用RKE（Rancher引擎）安装了我的库伯内特斯集群。 我的集群设置在rancher2的顶部。 我的节点是托管OVH服务器的虚拟机。 我设法让运行中的应用程序具有L7入口和ClusterIP服务，但每次我尝试使用L4负载平衡器时，负载平衡器都处于挂起状态。根据https://github.com/rancher/ranch
-
据我所知，作业对象应该在一定时间后收获豆荚。但是在我的GKE集群（库伯内特斯1.1.8）上，“kubectl get pods-a”似乎可以列出几天前的豆荚。 所有这些都是使用乔布斯API创建的。 我确实注意到在使用 kubectl 删除作业后，pod 也被删除了。 我在这里主要担心的是，我将在批量作业中在集群上运行成千上万个pod，并且不想让内部待办系统过载。
-
问题内容： 但是有很多歧义和提供的一些答案…包括在jars / executor / driver配置或选项中复制jar引用。 How ClassPath is affected Driver Executor (for tasks running) Both not at all Separation character: comma, colon, semicolon If provided
-
大家下午好，我有一个关于将应用程序本身的监控添加到prometheus的问题。我使用的是spring boot actuator，并相应地查看普罗米修斯的值：https://example.com/actuator/prometheus我通过默认头盔图表（）为它添加了默认值，从而提升了普罗米修斯： 普罗米修斯本身可以在http://ex.com/prometheus部署。我的springboot应
-
我有一个部署在远程Kubernetes集群上的Flink SessionCluster（根据文档），可在