Realtime Compute for Apache Flink:ドラフトのデバッグ

ステップ 1：セッションクラスタを作成する

1. セッションクラスタページに移動します。

   1. Apache Flink 用 Realtime Compute コンソール にログインします。

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

   3. 左側のナビゲーションウィンドウで、[O&M] > [セッションクラスタ] を選択します。

2. セッションクラスタページの左上隅にある [セッションクラスタの作成] をクリックします。

3. パラメータを構成します。

   次の表にパラメータを示します。

   セクション	パラメータ	説明
   [標準]	[名前]	作成するセッションクラスタの名前。
   	[デプロイメントターゲット]	ドラフトがデプロイされるキュー。 キューの作成方法の詳細については、「キューの管理」をご参照ください。
   	[状態]	クラスタの望ましい状態。 有効な値： [実行中]: クラスタは構成後も実行を続けます。 [停止]: クラスタは構成後に停止し、クラスタにデプロイされたデプロイメントも停止します。
   	[ラベルキー]	[ラベル] セクションでデプロイメントのラベルを構成できます。 これにより、[概要] ページでデプロイメントを効率的に見つけることができます。
   	[ラベル値]	該当なし
   [構成]	[エンジンバージョン]	現在のデプロイメントで使用される Flink エンジンのバージョン。 エンジンバージョンの詳細については、「エンジンバージョン」と「ライフサイクルポリシー」をご参照ください。 推奨バージョンまたは安定バージョンを使用することをお勧めします。 エンジンバージョンは次のタイプに分類されます。 [推奨]: 最新のメジャーバージョンの最新のマイナーバージョン。 [安定]: プロダクトのサービス期間内にあるメジャーバージョンの最新のマイナーバージョン。 以前のバージョンの欠陥は、このようなバージョンで修正されています。 [標準]: プロダクトのサービス期間内にあるその他のマイナーバージョン。 [非推奨]: プロダクトのサービス期間を超えたバージョン。
   	[flink 再起動ポリシー]	有効な値： [障害率]: 指定された間隔内の障害の数が上限を超えた場合、JobManager が再起動されます。 このオプションを選択する場合は、[障害率間隔]、[間隔ごとの最大障害数]、および [再起動試行間の遅延] パラメータを構成する必要があります。 [固定遅延]: JobManager は一定の間隔で再起動されます。 このオプションを選択する場合は、[再起動試行回数] と [再起動試行間の遅延] パラメータを構成する必要があります。 [再起動なし]: タスクが失敗しても JobManager は再起動されません。 重要 このパラメータを空のままにすると、デフォルトの Apache Flink 再起動ポリシーが使用されます。 この場合、タスクが失敗し、チェックポイントが無効になっていると、JobManager は再起動されません。 チェックポイントを有効にすると、JobManager が再起動されます。
   	[その他の構成]	taskmanager.numberOfTaskSlots: 1 などのその他の Flink 設定を構成します。
   [リソース]	[taskmanager の数]	デフォルトでは、値は並列度と同じです。
   	[jobmanager CPU コア]	デフォルト値：1。
   	[jobmanager メモリ]	最小値：1 GiB。 推奨値：4 GiB。 JobManager メモリは MiB 単位でも測定できます。 たとえば、このパラメータを 1024 MiB または 1.5 GiB に設定できます。
   	[taskmanager CPU コア]	デフォルト値：2。
   	[taskmanager メモリ]	最小値：1 GiB。 推奨値：8 GiB。 TaskManager メモリは MiB 単位でも測定できます。 たとえば、このパラメータを 1024 MiB または 1.5 GiB に設定できます。 各 TaskManager のスロット数と、TaskManager で使用可能なリソース量を指定することをお勧めします。 スロット数は、taskmanager.numberOfTaskSlots パラメータで指定されます。 このパラメータを構成するときは、次の点に注意してください。 単一の小さなデプロイメントの場合、単一スロットの CPU とメモリの比率を 1:4 に設定し、各スロットに少なくとも 1 CPU コアと 2 GiB のメモリを構成することをお勧めします。 複雑なデプロイメントの場合、各スロットに少なくとも 1 CPU コアと 4 GiB のメモリを構成することをお勧めします。 デフォルトのリソース構成を使用する場合は、各 TaskManager に 2 つのスロットを構成できます。 各 TaskManager にデフォルトのリソース構成を使用し、スロット数を 2 に設定することをお勧めします。 重要 TaskManager リソースが不足していると、TaskManager 上で実行されているデプロイメントの安定性に影響します。 さらに、スロット数を少なく設定すると、TaskManager のオーバーヘッドをタスクに効果的に分散できないため、リソースが十分に活用されません。 TaskManager に大量のリソースを構成すると、TaskManager 上で多数のデプロイメントが実行されることになります。 TaskManager に障害が発生した場合、すべてのデプロイメントが影響を受けます。
   [ロギング]	[ルートログレベル]	次のログレベルがサポートされており、重要度の低い順にリストされています。 TRACE: DEBUG ログよりも詳細な情報を記録します。 DEBUG: システムの状態を記録します。 INFO: 重要なシステム情報を記録します。 WARN: 潜在的なエラーに関する情報を記録します。 ERROR: 発生したエラーと例外に関する情報を記録します。
   	[ログレベル]	ログの名前とレベル。
   	[ロギングプロファイル]	ログテンプレート。 デフォルトまたはカスタムのプロファイルテンプレートを選択できます。

   説明

   Flink と Kubernetes や Yarn などのリソースオーケストレーションフレームワークとの統合に関連するオプションの詳細については、「リソースオーケストレーションフレームワーク」をご参照ください。

6. [セッションクラスタの作成] をクリックします。

   セッションクラスタが作成された後、ドラフトのデバッグまたはデプロイメントで使用できます。

ステップ 2：ドラフトをデバッグする

1. 左側のナビゲーションウィンドウで、[開発] > [ETL] を選択します。 デバッグする SQL ドラフトを選択します。

2. SQL エディターの右上隅にある [デバッグ] をクリックします。 [デバッグ] ダイアログボックスが表示されます。 [セッションクラスタ] ドロップダウンリストからセッションクラスタを選択します。 次に、[次へ] をクリックします。

3. デバッグデータを構成します。

   • デバッグにオンラインデータを使用する場合は、[確認] をクリックします。

   • モックデータを使用する場合は、[モックデータテンプレートのダウンロード] をクリックし、テンプレートにモックデータを入力してから、[モックデータのアップロード] をクリックしてテンプレートをアップロードします。

     次の表に、このステップのパラメータを示します。

     パラメータ	説明
     [モックデータテンプレートのダウンロード]	テンプレートは、ソーステーブルのスキーマに適合しています。
     [モックデータのアップロード]	モックデータを使用してドラフトをデバッグするには、モックデータテンプレートをダウンロードし、テンプレートを編集し、テンプレートをアップロードします。 次に、[モックデータを使用する] を選択します。 モックデータファイルの使用に関する制限： CSV ファイルのみがサポートされています。 CSV ファイルには、id(INT) などのテーブルヘッダーが含まれている必要があります。 CSV ファイルには最大 1,000 件のデータレコードを含めることができ、1 MB を超えることはできません。
     [データプレビュー]	モックデータをアップロードした後、ソーステーブル名の左側にある アイコンをクリックしてデータをプレビューし、モックデータをダウンロードします。
     [コードプレビュー]	デバッグ機能は、ソーステーブルと結果テーブルの DDL 文を自動的に変更します。 ただし、ドラフトコードは変更されません。 [コードプレビュー] の下部でコードの詳細をプレビューできます。

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

   [確認] をクリックすると、デバッグ結果が SQL スクリプトエディターの下部に表示されます。