FLINKジョブをキャンセルしているときにES接続を閉じるにはどうしたらいいですか？

Question

flink APIでリソース管理（init、closeなど）を行うメソッドを取得したいと考えています。

例えば、

私がフリンクするようにジョブをサブミットすると、いくつかのJDBC接続が確立されました。

ジョブをキャンセルすると、ジョブのキャンセル前にこれらの接続が閉じられました。

Answer 1

RichFunctionインターフェイスは、open()およびclose()メソッドを提供します。 open()は、タスクの開始時および最初のレコードが処理される前に呼び出されます。 close()は、失敗または目的のためにタスクがキャンセルされたときに呼び出されます。

ほとんどの機能には、MapFunctionの豊富なバリアント、すなわちRichMapFunctionが存在します。