すべてのプロダクト
Search
ドキュメントセンター

Realtime Compute for Apache Flink:状態セットの管理

最終更新日:Feb 20, 2025

デプロイメントのチェックポイントとセーブポイントをまとめて状態セットと呼びます。このトピックでは、状態(チェックポイントまたはセーブポイント)の作成、表示、削除、または特定の状態からのデプロイメントの復元など、デプロイメントの状態セットを管理する方法について説明します。

背景情報

用語

説明

チェックポイント

チェックポイントのライフサイクルは Flink によって管理されます。[チェックポイント間隔][チェックポイントタイムアウト時間][チェックポイント間の最小間隔] パラメーターを構成し、チェックポイント情報を表示できます。チェックポイントを手動で作成または削除することはできません。デフォルトでは、デプロイメントには 1 つのチェックポイントが保持されます。このチェックポイントは、デプロイメントを復元する場合に使用できます。チェックポイントパラメーターの構成方法の詳細については、「デプロイメントの構成」をご参照ください。

セーブポイント

セーブポイントのライフサイクルはユーザーのみが管理します。

  • セーブポイントは、デプロイメントの実行中またはデプロイメントのキャンセル時に、ユーザーが手動でトリガーできます。さらに、Ververica Platform(VVP)によって 1 回または定期的にトリガーすることもできます。

  • セーブポイントは、ユーザーが手動で、または VVP を介して 1 回または定期的に削除できます。

  • デプロイメントを開始するときに、指定したセーブポイントから復元できます。

説明

VVP はセーブポイントを定期的に作成およびリリースできますが、これらの操作はユーザー設定のルールに基づいて実行されるため、ユーザーの制御下にあります。

次の表は、特定のシナリオでチェックポイントとセーブポイントに対して実行できる操作の概要を示しています。詳細については、このトピックの関連セクションをご参照ください。

操作

シナリオ

参照

セーブポイントの手動作成

特定の時点(デプロイメントの実行中またはキャンセル時)でセーブポイントを手動で作成し、このセーブポイントからデプロイメントを復元する場合、セーブポイントを手動で作成できます。

重要
  • 手動で作成されたセーブポイントは手動でのみ削除できます。クリーンアップルールに基づいて自動的にリリースすることはできません。

  • デプロイメントのキャンセル時に [セーブポイントで停止] を選択すると、取得する必要があるデータ量が削減されます。ただし、デプロイメントのキャンセルには時間がかかります。

スケジュールされたセーブポイント作成の構成

システムが定期的にセーブポイントを自動的に作成するようにするには、セーブポイントのスケジュールされた生成を有効にし、セーブポイントが作成される間隔を指定します。スケジュールされたセーブポイント生成のルールが保存されると、デプロイメントの実行中にシステムは自動的にセーブポイントを作成します。

スケジュールされたセーブポイント生成の構成

状態生成の概要の表示

デプロイメントの [状態] タブで、チェックポイントとセーブポイントの作成履歴の概要を確認し、既存のチェックポイントとセーブポイント、および完了時刻をすばやく把握できます。

状態生成の概要の表示

特定のセーブポイントからのデプロイメントの再開

デプロイメントを復元するセーブポイントを指定できます。

説明

デプロイメント間でセーブポイントを共有するには、デュアルランテストなどの手段でデプロイメント間の状態データに互換性があることを確認してください。

別のデプロイメントの指定されたセーブポイントからデプロイメントを復元する

セーブポイントの自動クリーンアップルールの構成

VVP がセーブポイントを自動的に削除するようにするには、保存できる履歴セーブポイントの最大数またはセーブポイントの保持期間を構成します。セーブポイントの自動クリーンアップルールが保存されると、デプロイメントの実行中にシステムはルールに基づいてセーブポイントを自動的に削除します。

説明
  • 自動クリーンアップでは、手動で作成されたセーブポイントは削除されません。手動で削除する必要があります。

  • デプロイメントが長期間中断されている場合、デプロイメントの起動時にシステムはクリーンアップルールに基づいてセーブポイントを削除します。

セーブポイントの自動クリーンアップルールの構成

特定のセーブポイントの手動削除

手動で作成されたセーブポイントは、デプロイメントの実行中に自動的に削除されなくなりました。そのため、古いセーブポイントは定期的に削除する必要があります。そうしないと、Object Storage Service(OSS)ストレージで不要なスペースを占有し、追加料金が発生します。

特定のセーブポイントを手動で削除する

状態関連パラメーターの構成

ストリーミング状態バックエンド、SQL デプロイメントの状態の生存時間(TTL)、セーブポイントの作成中に生成された一時データをローカルディスクに保存するかどうかなど、状態関連パラメーターを構成できます。

状態関連パラメーターの構成

セーブポイントを手動で作成する

説明

[実行中] のデプロイメントに対してのみ、セーブポイントを手動で作成できます。

  1. セーブポイント作成ダイアログボックスを開きます。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

  2. ページの右上隅にある [セーブポイントの作成] をクリックします。

  3. [セーブポイントの作成] ダイアログボックスで、[形式] パラメーターを構成し、[説明] フィールドにセーブポイントの説明を入力します。

    创建快照

  4. [作成] をクリックします。

スケジュールされたセーブポイント作成の構成

  1. [状態] タブに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、コンソール[アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

    4. [状態] タブに切り替えます。

  2. [構成] サブタブで、[定期的に自動生成されるセーブポイント] をオンにし、[期間設定] パラメーターを構成します。

    [クイック設定] をクリックして、ドロップダウンリストからオプションを選択できます。また、CRON 式を使用して間隔を指定することもできます。[期間設定] パラメーターで変更するフィールドをクリックし、各フィールドの値を変更します。次の表は、CRON 式の 5 つのフィールドの有効値とサポートされている特殊文字について説明しています。

    フィールド

    必須

    有効値

    サポートされている特殊文字

    サポートされている

    [0, 59]

    * , - /

    サポートされている

    [0, 23]

    * , - /

    サポートされている

    [1, 31]

    * , - /

    サポートされている

    [1, 12] または [JAN, DEC]

    * , - /

    曜日

    サポートされている

    [1, 7] または [MON, SUN]

    説明

    [1, 7] 形式では、1 は月曜日、7 は日曜日を示します。

    * , - /

    説明

    最小間隔は 10 分です。CRON 式で指定した間隔が 10 分未満の場合、システムは 10 分間隔でセーブポイントを自動的に作成します。

    次の表は、CRON 式の各フィールドでサポートされている特殊文字の意味について説明しています。

    サポートされている特殊文字

    意味

    Cron 式

    *

    任意の有効値を示します。

    [月] フィールドのアスタリスク(*)は毎月を示します。[曜日] フィールドのアスタリスク(*)は曜日の毎日を示します。

    ,

    列挙値を一覧表示します。

    [分] フィールドの 5,20 は、タスクが 5 分目と 20 分目に 1 回トリガーされることを示します。

    -

    範囲を示します。

    [分] フィールドの 5-20 は、タスクが 5 分目から 20 分目まで毎分 1 回トリガーされることを示します。

    /

    増分を示します。

    [分] フィールドの 0/15 は、タスクが 1 時間の最初から 15 分ごとに 1 回トリガーされることを示します。[分] フィールドの 3/20 は、タスクが 1 時間の 3 分目から 20 分ごとに 1 回トリガーされることを示します。

    次の表は、CRON 式のサンプル値について説明しています。

    Cron 式

    説明

    15 10 * * *

    毎日 10:15 にタスクを実行します。

    0 12 * * *

    毎日 12:00 にタスクを実行します。

    0 10,14,16 * * *

    毎日 10:00、14:00、16:00 にタスクを実行します。

    0/30 9-17 * * *

    毎日 09:00 から 17:00 までの間、30 分ごとにタスクを実行します。

    * 14 * * *

    毎日 14:00 から 14:59 までの間、毎分タスクを実行します。

    0-5 14 * * *

    毎日 14:00 から 14:05 までの間、毎分タスクを実行します。

    0/5 14 * * *

    毎日 14:00 から 14:55 までの間、5 分ごとにタスクを実行します。

    0/5 14,18 * * *

    毎日 14:00 から 14:55 までと 18:00 から 18:55 までの間、5 分ごとにタスクを実行します。

    0 12 * * WED

    毎週水曜日の 12:00 にタスクを実行します。

    15 10 15 * *

    毎月の 15 日の 10:15 にタスクを実行します。

    10,44 14 * 3 WED

    毎年 3 月の毎週水曜日の 14:10 と 14:44 にタスクを実行します。

  3. [変更の保存] をクリックします。

状態生成の概要の表示

  1. [状態] タブに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

    4. [状態] タブに切り替えます。

  2. [概要] サブタブの [状態] タブで、チェックポイントとセーブポイントの情報を表示します。

    項目

    説明

    チェックポイント

    チェックポイント ID、完了時刻、期間、サイズなど、最後に成功したチェックポイントと失敗したチェックポイントに関する情報を表示できます。

    セーブポイント

    スナップショット ID、完了時刻、期間、失敗時刻など、最後に成功したセーブポイントと失敗したセーブポイントに関する情報を表示できます。

特定のセーブポイントからデプロイメントを再開する

説明

指定されたセーブポイントから [キャンセル済み] のデプロイメントのみを復元できます。デプロイメントが [実行中] の場合は、最初にデプロイメントをキャンセルする必要があります。

  1. [状態] タブに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

    4. [状態] タブに切り替えます。

  2. 履歴[状態] タブの セーブポイント サブタブをクリックします。 セクションで、ターゲット セーブポイントを見つけます。

  3. [詳細] > [このスナップショットからジョブを開始][アクション] 列で選択します。

  4. [ジョブの開始] ダイアログボックスで、起動パラメーターを構成します。

    構成の詳細については、「デプロイメントを開始する」をご参照ください。

セーブポイントの自動クリーンアップルールの構成

  1. [状態] タブに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

    4. [状態] タブに切り替えます。

  2. [構成] サブタブの [状態] タブで、[セーブポイントのスケジュールされた自動クリーニング] をオンにして、セーブポイントの自動クリーンアップ ルールを構成します。

    [保存されている履歴スナップショットの数] パラメーターと [履歴スナップショットを保存する最大時間(単位:時間)] パラメーターを構成できます。デプロイメントの実行中にいずれかの条件が満たされると、システムは自動的にセーブポイントを削除します。

  3. [変更の保存] をクリックします。

特定のセーブポイントを手動で削除する

  1. [状態] タブに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

    4. [状態] タブに切り替えます。

  2. 履歴[状態] タブの セーブポイント サブタブをクリックします。 セクションで、ターゲット セーブポイントを見つけます。

  3. [その他] > [このセーブポイントを削除][アクション] 列で選択します。

  4. [OK] をクリックします。

状態関連パラメーターの構成

  1. ターゲット デプロイメントページに移動します。

    1. Realtime Compute for Apache Flink の管理コンソール にログインします。

    2. ターゲット ワークスペースを見つけ、[コンソール][アクション] 列の をクリックします。

    3. 左側のナビゲーションウィンドウで、[O&M] > [デプロイメント] を選択します。[デプロイメント] ページで、ターゲット デプロイメントの名前をクリックします。

  2. パラメーター[構成] タブの 編集 セクションの右上隅にある をクリックします。

  3. [その他の構成] フィールドに次のコードを追加し、[保存] をクリックします。

    state.backend.incremental: true
    table.exec.state.ttl: 129600000

    Realtime Compute for Apache Flink のコンソールで構成できる基本パラメーターと詳細パラメーターの詳細については、「GeminiStateBackend の構成」をご参照ください。

参照