一种容器编码调度引擎上Flink的健康监测方法和装置

著录项目

摘要

本发明公开了一种容器编码调度引擎上Flink的健康监测方法和装置，涉及流式计算技术领域。该方法的一具体实施方式包括：将Flink部署在容器编码调度引擎上，以实现Flink容器化；利用Flink的主节点接收Flink业务，调度Flink的从节点创建业务进程，以对Flink业务进行处理，并在业务进程的处理过程中，定时向主节点和从节点分别对应的心跳文件中写入心跳时间戳；通过容器编码调度引擎上的健康监测探针调用健康监测脚本，查询业务进程对应的心跳文件，根据心跳文件中的心跳时间戳和当前时间，确定flink的健康状态。该实施方式降低了故障恢复所需时长，提高了Flink的计算效率，提高了开源系统的系统稳定性和可用性，提升了用户体验。

附图

附图 1