Realtime Compute for Apache Flink のリソースキューは、名前空間内のデプロイメント間で計算リソースを隔離し、割り当てます。各名前空間には、default-queue という名前のデフォルトキューが含まれています。単一のデプロイメントまたはユーザーが利用可能なすべてのリソースを消費し、他のユーザーに障害を引き起こすことを防ぐために、カスタムキューを作成します。
注意事項
キューは排他モードでのみ実行できます。キューはプリエンプションモードでは実行できません。キューがプリエンプションモードで実行されている場合、キュー内のリソースはプリエンプトできません。
キュー内の特定のリソースがリリースされると、そのリソースは新しいデプロイメントで使用できます。
カスタムキューが存在しない場合、すべてのデプロイメントは
default-queueで実行されます。
ワークロードへのキューの割り当て
| ワークロードタイプ | 設定場所 | パラメーター | 関連ドキュメント |
|---|---|---|---|
| デプロイメント | [Deploy draft] ダイアログボックス | [Deployment Target] | デプロイメントの作成 |
| セッションクラスター | [標準] セクション、[セッションクラスターの作成] ページ | [Deployment Target] | セッションクラスターの作成 |
| ワークフロー | [ワークフローの作成] パネル | リソースキュー | ワークフローの管理 |
共通のコンソール手順
追加、編集、削除の手順はすべて、同じナビゲーション手順から始まります。
対象のワークスペースを見つけ、[コンソール] を [操作] 列でクリックします。
左側のナビゲーションウィンドウで、O＆M ＞ キュー管理 を選択します。
キューの追加
キュー名のルール
| ルール | 詳細 |
|---|---|
| 一意性 | 名前空間内で一意である必要があります |
| 長さ | 最大 32 文字 |
| 文字 | 小文字、数字、およびハイフン (-) のみ |
| 変更可能性 | 作成後は変更できません |
手順
共通のコンソール手順を完了します。
キュー管理ページの左上隅で、[キューの追加] をクリックします。
キューパラメーターを設定します。パラメーターは、伸縮性リソースが名前空間に割り当てられているかどうかによって異なります。
伸縮性リソースのない名前空間
ワークスペースの課金方法が従量課金、サブスクリプション、または ハイブリッド課金であり、伸縮性リソースが名前空間に割り当てられていない場合に適用されます。
パラメーター 説明 キュー名 キュー名のルールに従って名前を入力します。 リソース (CU) キューで利用可能な CU の数。最大値は、名前空間内の残りの未割り当て CU と同じです。十分な CU が利用できない場合は、他のキューで CU を再設定するか (キューの編集をご参照ください)、名前空間のリソースを増やします (リソースの再設定をご参照ください)。 伸縮性リソースのある名前空間
ワークスペースの課金方法が ハイブリッド課金であり、伸縮性リソースが名前空間に割り当てられている場合に適用されます。
パラメーター 説明 [キュー名] キュー名のルールに従って名前を入力します。 [固定リソース (CU)] キューで利用可能な固定 CU 数です。利用可能な固定 CU が不足している場合は、サブスクリプションのワークスペースを使用してリソースを調整します。詳細については、「リソースの再設定」をご参照ください。 [弾性リソース (CU)] キューで利用可能な弾性 CU 数です。[キュー管理] ページには、割り当て可能な最大の弾性 CU が表示されます。利用可能な弾性 CU が不足している場合は、従量課金のワークスペースを使用してリソースを調整します。詳細については、「リソースの再設定」をご参照ください。 [OK] をクリックします。
キューの編集
リソースのニーズが変化したときに、既存のキューの CU 割り当てを調整します。
共通のコンソール手順を完了します。
対象のキューを探し、「アクション」列の [編集] をクリックします。
[キューの編集] ダイアログボックスで、リソースの値を更新します。パラメーターの説明については、「キューの追加」をご参照ください。
重要[リソース (CU)] の値は、キューで現在使用されている CU 数より低く設定することはできません。
[OK] をクリックします。
キューの削除
デフォルトキュー (
default-queue) は削除できません。実行中のデプロイメントがあるキューは削除できません。
デプロイメントが参照するキューを削除すると、そのデプロイメントが再起動したときにエラーが発生します。
共通のコンソール手順を完了します。
対象のキューを見つけ、「操作」列の [削除] をクリックし、[OK] をクリックします。
ユースケース
バッチワークロードの分離: バッチデプロイメントを専用キューに割り当てることで、他のジョブのリソース枯渇を防ぎます。
重要なジョブの優先順位付け: キューと Workflows (パブリックプレビュー) 機能を組み合わせて、バッチドラフトのスケジューリング優先順位を設定します。
参考資料
リソースの再設定 -- 名前空間のリソースまたはクォータ制限を調整します。
デプロイメントの作成 -- SQL、JAR、または Python デプロイメントを作成します。
セッションクラスターの作成 -- デバッグ用のセッションクラスターをセットアップします。
Workflows (パブリックプレビュー) -- バッチデプロイメントをスケジュールし、優先順位を付けます。