Realtime Compute for Apache Flink:デプロイメントの開始

前提条件

既存のデプロイメントが必要です。詳細については、「デプロイメントの作成」をご参照ください。

制限事項

起動オプションは、ストリーミングデプロイメントでのみ指定できます。

注意事項

• RAM ユーザー、RAM ロール、または別の Alibaba Cloud アカウントがデプロイメントを開始する場合、対応するアイデンティティがターゲット名前空間にアクセスできることを確認してください。詳細については、「フルマネージド Flink コンソールへのアクセスの承認」および「権限の管理」をご参照ください。

• 「最新ステート」または「特定ステート」オプションを使用してデプロイを開始すると、システムはステート互換性チェックを実行します。 検出された非互換性がある状態でデプロイを開始すると、失敗したり、予期しない結果が生じたりする可能性があるため、リスクが伴います。 詳細については、「Flink ステート互換性リファレンス」をご参照ください。

操作手順

1. デプロイメントの開始ダイアログを開きます。

   1. 名前空間の所有者ロールを持つユーザーとしてフルマネージド Flink コンソールにログインします。

   2. 上部メニューで、対象の名前空間を選択します。

   3. [運用 & 保守] > [Deployments] ページで、ドロップダウンリストから [streaming deployment] または [batch deployment] を選択します。

2. 対象のデプロイメントを見つけ、[操作] 列で [Start] をクリックします。

3. (オプション) ストリーミングデプロイメントの場合、起動オプションを設定します。

   • [Initial mode]

     このモードは、新しいデプロイメントの場合、または既存の状態を再利用できない場合に選択します。ビジネス要件に基づいて、Autopilot を有効にするかどうかを決定することもできます。

     説明

     イニシャルモードは、ステートを再利用しないステートレスな起動です。ソースコネクタの観点からは、これは初回起動と等価であるため、DDL で設定された起動位置パラメーターが再度有効になります。たとえば、MySQL CDC ソーステーブルで scan.startup.mode を latest-offset に設定した場合、イニシャルモードで起動されると、デプロイメントは現在の最新のオフセットからのみ読み取り、完全な履歴データは再スキャンしません。デフォルト値の initial が保持されている場合、デプロイメントは完全な履歴データを再スキャンします。

     Simple Log Service (SLS) のログ保持期間やメッセージキューのメッセージ保持期間など、上流ストレージにデータ保持期間の制限がある場合、Initial モードでの起動後に再度読み込まれるデータ範囲は、その保持期間の制約を受け、初回実行時のデータ範囲とは異なる場合があります。下流シンクがプライマリキーに基づいてデータを上書きする場合は、結果テーブルでの予期せぬ上書きを防ぐため、Initial モードでデプロイを開始する前に上流のデータ保持期間を評価してください。

     戦略	説明
     [Specify source's start time]	[Specify source's start time] を選択し、特定の時間を入力します。 UI で開始時刻を設定できるコネクターは、Kafka、Log Service (SLS)、DataHub、ApsaraMQ for RocketMQ、Hologres、Paimon、MySQL の 7 つです。 デプロイメントの起動インターフェイスで指定したデータ読み取り時間は、デプロイメントの DDL コードで設定した startTime よりも優先されます。 説明 0.11 より前の Kafka バージョンは、コネクターが使用する Kafka クライアントのバージョンとの互換性がない可能性があるため、サポートされていない場合があります。Kafka のバージョンをアップグレードすることを推奨します。 すべてのコネクターが startTime パラメーターの設定をサポートしているわけではありません。詳細については、各コネクターの WITH パラメーター (「Log Service (SLS) の WITH パラメーター」など) を参照して、startTime が含まれているかどうかを確認してください。 新しいデプロイメントを開始し、startTime を指定した場合にのみ startTime は有効になります。チェックポイントまたはセーブポイントからデプロイメントを開始する場合、startTime を指定しても効果はありません。
     [Configure Autopilot]	このスイッチをオンにして、チューニングモードを選択します： Autopilot モード： システムは、使用率が低いときにはリソースを自動的にスケールダウンし、使用率が特定のしきい値に達したときにはスケールアップします。詳細については、「Autopilot の有効化と設定」をご参照ください。 スケジュールモード： ドロップダウンリストからスケジュールを選択する必要があります。スケジュールには、さまざまな時点での複数のリソース設定を含めることができます。さまざまな期間の使用パターンに基づいてリソースを設定できます。詳細については、「スケジュールされたチューニングプランの設定と適用」をご参照ください。

   • [Resume mode]

     ビジネス要件に基づいて起動戦略を選択し、Autopilot を有効にするかどうかを決定できます。

     戦略	説明
     [Latest State]	利用可能な最新の セーブポイント または チェックポイント からデプロイメントを再開します。SQL デプロイメントでこのオプションを選択すると、Flink システムは SQL コード、Flink ランタイムパラメーター、およびエンジンバージョンの変更を検出します。 [State Compatibility] の横にある [Click to detect] をクリックして互換性を確認することを推奨します。その後、結果に基づいて処理を進めてください。互換性の結果と推奨されるアクションについては、「互換性」をご参照ください。
     [Specific State]	再開する特定のセーブポイントを選択します。セーブポイントの作成方法については、「デプロイメント状態の管理」をご参照ください。
     [Other deployment state]	このオプションを選択した後、再開元のターゲットデプロイメントとそれに対応するセーブポイントを指定します。セーブポイントはデプロイメント間で共有できますが、状態に互換性がある必要があります。詳細については、「デプロイメント状態の管理」をご参照ください。
     [Allow Non-restored State (AllowNonRestoredState)] 説明 このオプションは JAR デプロイメントでのみサポートされています。	デフォルトでは、Flink はセーブポイント全体を新しいデプロイメントのオペレーターにマッピングしようとします。デプロイメントの変更によってオペレーターの状態が変更されると、デプロイメントの再開に失敗する可能性があります。このオプションを有効にすると、Flink はマッピングできない状態をスキップして起動を続行できます。詳細については、「復元されない状態の許可」をご参照ください。
     [Configure Autopilot]	このスイッチをオンにして、チューニングモードを選択します： Autopilot モード： システムは、使用率が低いときにはリソースを自動的にスケールダウンし、使用率が特定のしきい値に達したときにはスケールアップします。詳細については、「Autopilot の有効化と設定」をご参照ください。 スケジュールモード： ドロップダウンリストからスケジュールを選択する必要があります。スケジュールには、さまざまな時点での複数のリソース設定を含めることができます。さまざまな期間の使用パターンに基づいてリソースを設定できます。詳細については、「スケジュールされたチューニングプランの設定と適用」をご参照ください。

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

   [運用 & 保守] > [Deployments] ページで、デプロイメントのステータスを確認します。詳細については、「デプロイメントステータスの表示」をご参照ください。

関連ドキュメント

• デプロイメントの開始後、ランタイムパラメーターを変更する必要がある場合は、「ランタイムパラメーターの設定」をご参照ください。一部のパラメーターは動的なパラメーター更新もサポートしており、これによりデプロイメントの停止と再起動に伴うダウンタイムを回避できます。詳細については、「動的スケーリングと動的パラメーター更新」をご参照ください。

• デプロイメントの開始後、データのトレースを行って問題の特定や影響の評価を行う必要がある場合は、「データリネージュの表示」をご参照ください。

• エンタープライズグレードの GeminiStateBackend と RocksDBStateBackend とのパフォーマンス比較については、「エンタープライズグレードのステートバックエンドの概要」をご参照ください。