我有一个基于flink1.4.2的flink独立集群(1个作业管理器,4个任务槽),我想提交两个不同的flink程序。不确定这是否可能,因为一些flink档案说一个作业管理器只能运行一个作业。如果这是真的,我有什么想法可以绕过这个问题吗?flink集群只有一台可用的机器,我们不想使用任何资源管理器,如mesos或yarn。有什么提示吗?
watbbzwu1#
flink作业(程序)在任务管理器中的任务槽中运行。假设您有4个任务槽,您最多可以运行4个flink程序。另外,要注意你的flink工作的并行性。如果在两个作业中都将并行度设置为2,那么yes 2是可以在4个任务槽上运行的最大作业数。每个并行示例在一个任务槽上运行。检查此图像:https://ci.apache.org/projects/flink/flink-docs-master/fig/slots_parallelism.svg
1条答案
按热度按时间watbbzwu1#
flink作业(程序)在任务管理器中的任务槽中运行。假设您有4个任务槽,您最多可以运行4个flink程序。另外,要注意你的flink工作的并行性。如果在两个作业中都将并行度设置为2,那么yes 2是可以在4个任务槽上运行的最大作业数。每个并行示例在一个任务槽上运行。
检查此图像:https://ci.apache.org/projects/flink/flink-docs-master/fig/slots_parallelism.svg