このトピックでは、リアルタイムモードでの Ververica Flink ストリームバッチ統合タスクのリソースを設定する方法について説明します。本番環境と開発環境のクラスターとエンジンバージョンを設定できます。また、並列度、JobManager とタスクマネージャーの CPU とメモリも設定できます。
手順
Dataphin のホームページで、上部のメニューバーから [開発] > [データ開発] に移動します。
上部のメニューバーから [プロジェクト] を選択します。Dev-Prod モードの場合は、[環境] も選択する必要があります。
左側のナビゲーションウィンドウで、[データ処理] > [スクリプトタスク] を選択します。右側のコンピューティングタスクのリストで、対象のコンピューティングタスクをクリックします。
右側のサイドバーで [設定] をクリックします。表示されるパネルで、[リアルタイムモード] タブをクリックします。
リアルタイムモード設定パネルの [リソース設定] セクションで、[リソース設定] の各項目を設定できます。
パラメーター
説明
本番環境クラスター
タスク作成時に選択した本番環境のクラスターがデフォルトで使用されます。ここでクラスターを切り替えることができます。
重要注意：クラスターを切り替えると、送信後のタスク実行に影響が出る可能性があります。操作は慎重に行ってください。
本番環境エンジンバージョン
タスク作成時に選択した本番環境のエンジンバージョンがデフォルトで使用されます。ここでエンジンバージョンを切り替えることができます。
開発環境のクラスターとエンジンバージョン
システムのデフォルト設定を使用するか、カスタム設定を指定できます。
[システムのデフォルト設定]：デフォルトのオプションです。本番環境と同じクラスターとエンジンバージョンを使用します。
[カスタム設定]：開発環境でのタスク実行に使用するクラスターとエンジンバージョンを選択できます。
説明注意：プロジェクトが Basic モードの場合、この項目を設定する必要はありません。
並列度
デフォルト値は 4 です。0 より大きい任意の整数を入力できます。値 -1 は自動推論を示します。
タスクマネージャー数
デフォルト値は 2 です。0 より大きい任意の整数を入力できます。
タスクマネージャー CPU
デフォルト値は 1 です。1 や 10.5 など、0 より大きい任意の数値を入力できます。
タスクマネージャー メモリ
デフォルト値は 8 Gi です。単位として Gi または Mi を使用します。1024000 のようなバイト単位の数値、または 1024 Mi や 1.5 Gi のようなメモリ単位付きの数値を入力できます。
JobManager CPU
タスクが Flink クラスターのコントロールユニットで占有する CPU リソースの量です。デフォルト値は 1 です。1 や 10.5 など、0 より大きい任意の数値を入力できます。
JobManager メモリ
タスクが Flink クラスターのコントロールユニットで占有するメモリリソースの量です。デフォルト値は 4 Gi です。単位として Gi または Mi を使用します。1024000 のようなバイト単位の数値、または 1024 Mi や 1.5 Gi のようなメモリ単位付きの数値を入力できます。
リソース構成タイプ
システム推奨設定
これは、リアルタイムコンピューティング Flink での詳細なリソース設定のためのインテリジェントモード (BETA) です。インテリジェントモードは、エキスパートモードのアップグレード版です。インテリジェントモードでは、ジョブはエキスパートモードのリソース設定を使用し、AutoPilot 自動チューニング機能を有効にします。
自動構成モードでは、関連リソースを構成する必要はありません。 Autopilot は、ジョブのリソース構成を自動的に生成し、ジョブのステータスに基づいてリソース構成を調整します。 これにより、ジョブの正常性に影響を与えることなく、ジョブのリソース使用率が最適化されます。 詳細については、「Autopilot を構成する」をご参照ください。
カスタム設定
これは、リアルタイムコンピューティング Flink での詳細なリソース設定のためのエキスパートモード (BETA) です。これは、フルマネージド Flink によって導入された新しいリソース設定モードです。スループット要件を満たすために、ジョブリソースの詳細なコントロールをサポートします。
システムは、設定したリソース要件に基づいてネイティブ K8s モードでジョブを自動的に実行し、スロット仕様とジョブの同時実行数に基づいてタスクマネージャー (TM) の仕様と数を自動的に決定します。詳細については、「ジョブのデプロイメントを設定する」をご参照ください。
Dataphin で Flink SQL タスクのリソースをカスタマイズするには、「Ververica Flink リアルタイムタスクのリソースをカスタマイズする」をご参照ください。
説明注意：Flink DataStream タスクは、[リソース設定タイプ] の設定をサポートしていません。
リソース設定レコード
[リソース構成] 情報が変更された場合、[現在の構成を新しいレコードとして保存] をクリックできます。 保存されたリソース構成レコードでは、[詳細の表示]、[開始]、または[削除]を行うことができます。
説明Flink DataStream タスクは [リソース設定レコード] をサポートしていません。
[OK] をクリックして設定を保存します。