java - 如何在取消 FLINK 作业的同时关闭 ES 连接？

Question

我想获取flink API中进行资源管理的方法(例如init、close)。

例如。

当我向 flink 提交作业时，建立了一些 JDBC 连接。

当我取消作业时，这些连接会在作业取消之前关闭。

Answer 1

RichFunction 接口(interface)提供 open() 和 close() 方法。 open() 在任务启动时和处理第一条记录之前调用。 close() 当任务因失败或故意取消时被调用。

对于大多数函数来说，都存在丰富的变体，即 MapFunction 的 RichMapFunction。