開発およびデプロイしたデプロイメントは、開始する必要があります。また、停止したデプロイメントを再開する場合や、再起動が必要な設定変更を適用する場合にも、デプロイメントを開始する必要があります。
前提条件
デプロイメントが作成済みである必要があります。詳細については、「デプロイメントのデプロイ」をご参照ください。
制限事項
起動オプションは、ストリーミングデプロイメントでのみ利用可能です。
注意事項
-
RAM ユーザー、RAM ロール、または別の Alibaba Cloud アカウントがデプロイメントを開始する場合、そのアカウントがターゲットの名前空間にアクセスするために必要な権限があることを確認してください。詳細については、「コンソールでのアクセス承認」および「権限の管理」をご参照ください。
-
最新の状態または特定の状態からデプロイメントを開始すると、システムは状態の互換性チェックを実行します。状態の互換性に問題があるデプロイメントを開始すると、起動の失敗や予期しない結果につながる可能性があります。詳細については、「Flink の状態の互換性リファレンス」をご参照ください。
操作手順
-
デプロイメントページに移動します。
-
Realtime Compute for Apache Flink コンソールにログインします。
-
上部メニューで、ターゲットの名前空間を選択します。
-
ペインで、ドロップダウンリストから [STREAM] または [BATCH] を選択します。
-
-
ターゲットのデプロイメントを見つけ、[操作] 列の [Start] をクリックします。
-
(オプション) ストリーミングデプロイメントの場合、起動オプションを設定します。
-
[初期モード]
このモードは、新しいデプロイメントを起動したり、以前の状態を使用せずにデプロイメントを開始したりするために使用します。
戦略
説明
[ソースの開始時刻の指定]
[Specify source's start time] を選択し、時刻を指定します。
Kafka、SLS、DataHub、ApsaraMQ for RocketMQ、Hologres、Paimon、および MySQL コネクタのソース開始時刻を設定できます。
デプロイメントの開始ページで指定した開始時刻は、デプロイメントの DDL コードで設定された startTime パラメーターを上書きします。
説明-
Kafka の 0.11 より前のバージョンは、コネクタのクライアントバージョンとの互換性の問題が発生する可能性があるため、サポートされていない場合があります。Kafka のバージョンをアップグレードすることを推奨します。
-
すべてのコネクタが startTime パラメーターをサポートしているわけではありません。サポート状況を確認するには、特定のコネクタの WITH 句に startTime パラメーターが含まれているかどうかを確認してください。例については、「SLS の WITH パラメーター」をご参照ください。
-
startTime パラメーターは、このオプションで開始された新しいデプロイメントにのみ有効です。システムの チェックポイントまたは セーブポイントからデプロイメントを再開する場合は無視されます。
[自動チューニングの設定]
このオプションを有効にした後、チューニングモードを選択します:
-
[Autopilot モード]:システムは、使用率が低いときにリソースを自動的にスケールダウンし、使用率が特定のしきい値を超えたときにスケールアップします。詳細については、「Autopilot モードの有効化と設定」をご参照ください。
-
[Scheduled モード]:ドロップダウンリストからスケジュールを選択します。スケジュールには、異なる時間にマッピングされた複数のリソース設定を含めることができます。各期間の使用パターンに基づいてリソースを設定できます。詳細については、「スケジュールされたチューニングプランの設定と適用」をご参照ください。
-
-
[再開モード]
起動戦略を選択します。
戦略
説明
[最新の状態から再開]
最新のセーブポイントまたはシステムのチェックポイントからデプロイメントを再開します。Flink は、SQL コード、Flink ランタイムパラメーター、およびエンジンバージョンの変更を検出します。
変更が検出された場合は、[State Compatibility] の横にある [Click to detect] をクリックします。結果と推奨されるアクションの詳細については、「互換性」をご参照ください。
[指定した状態から再開]
再開に使用する特定のセーブポイントを選択します。セーブポイントの作成方法については、「デプロイメントの状態の管理」をご参照ください。
別のデプロイメントから再開
このオプションを選択して、再開の基点となるターゲットデプロイメントとそれに対応するセーブポイントを指定します。デプロイメント間でセーブポイントを共有できますが、デプロイメント間で状態に互換性がある必要があります。詳細については、「デプロイメントの状態の管理」をご参照ください。
[未復元状態の許可]
説明このオプションは JAR デプロイメントでのみサポートされています。
デフォルトでは、Flink はセーブポイントから新しいデプロイメントのオペレーターにすべての状態をマッピングしようとします。デプロイメントが変更されている場合、このマッピングは失敗する可能性があります。このオプションを有効にすると、Flink はマッピングできない状態をスキップしてデプロイメントを開始できます。詳細については、「未復元状態の許可」をご参照ください。
[自動チューニングの設定]
このオプションを有効にした後、チューニングモードを選択します:
-
[Autopilot モード]:システムは、使用率が低いときにリソースを自動的にスケールダウンし、使用率が特定のしきい値を超えたときにスケールアップします。詳細については、「Autopilot モードの有効化と設定」をご参照ください。
-
[Scheduled モード]:ドロップダウンリストからスケジュールを選択します。スケジュールには、異なる時間にマッピングされた複数のリソース設定を含めることができます。各期間の使用パターンに基づいてリソースを設定できます。詳細については、「スケジュールされたチューニングプランの設定と適用」をご参照ください。
-
-
-
[Start] をクリックします。
ページで、デプロイメントのステータスを確認します。詳細については、「デプロイメントのステータスの表示」をご参照ください。
関連ドキュメント
-
デプロイメントの開始後、そのランタイムパラメーターを変更できます。詳細については、「ランタイムパラメーターの設定」をご参照ください。一部のパラメーターは動的な更新もサポートしており、再起動を回避することでサービス停止時間を短縮します。詳細については、「動的スケーリングとパラメーターの更新」をご参照ください。
-
デプロイメントが実行中になると、そのデータリネージを追跡して問題を特定したり、影響を評価したりできます。詳細については、「データリネージの表示」をご参照ください。
-
エンタープライズグレードの状態バックエンドである GeminiStateBackend と、RocksDBStateBackend とのパフォーマンス比較については、「GeminiStateBackend の概要」をご参照ください。