在取消Flink作业时，如何关闭ES连接

Question

我想获取用于在Flink API中进行资源管理（例如Init，Close）的方法。

例如。

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

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

Answer 1

RichFunction接口提供open()和close()方法。启动任务和第一个记录之前，调用open()。由于故障或故意取消任务时，close()被调用。

对于大多数功能，存在丰富的变体，即RichMapFunction，用于MapFunction。