gpt4 book ai didi

kubernetes - Flink-在Kubernetes上部署Flink应用程序的多个实例

转载 作者:行者123 更新时间:2023-12-02 12:25:40 25 4
gpt4 key购买 nike

我需要有关在K8上进行Flink应用程序部署的帮助
我们有3个源将以SQL查询的形式发送触发条件。总查询量约为3-6k,实际上对flink实例而言是沉重的负担。我尝试执行,但是速度很慢,并且需要很多时间才能开始。
由于查询量很大,我们决定为每个源创建多个flink应用程序实例。因此,一个有效的flink实例将仅执行约1-2K查询。
示例:sql查询源是A,B,C
Flink实例:
应用A->仅负责处理源A查询
应用B->仅负责处理源B查询
App C->将仅负责处理源C查询
我想在Kubernetes上部署这些实例
题:
a)是否可以使用迷你集群(内置)部署独立的flink jar?就像刚启动主方法一样:Java -cp mainMethod(sourceName是命令行参数A / B / C)。
b)如果k8的一个pod或flink实例关闭,那么我们如何在另一个pod或另一个flink实例中对其进行管理?是否可以将工作交给其他Pod或其他flink实例?
对不起,如果我将两件事或更多件事混在一起:(
感谢您的帮助。谢谢

最佳答案

抛开一次语义的问题,解决此问题的一种方法是拥有发出SQL查询的并行源函数(每个子任务一个)和执行查询的下游FlatMapFunction(每个子任务一个) 。然后,您的源就可以发送对查询的更新,而不必强制您重新启动工作流。

关于kubernetes - Flink-在Kubernetes上部署Flink应用程序的多个实例,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63554920/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com