Ververica Flink リアルタイムタスクリソースのカスタマイズは、リアルタイムコンピューティング Flink の詳細なリソース構成のエキスパートモード (BETA) です。フルマネージド Flink によって導入されたこの新しいモードは、スループットの需要を満たすためにジョブリソースの正確なリソース制御をサポートします。システムは、指定されたリソース要件に従って Native K8s モードでジョブを自動的に実行し、Slot の仕様とジョブの同時実行性に基づいてタスクマネージャー (TM) の仕様と数を決定します。このトピックでは、Dataphin で Ververica Flink リアルタイムタスクのリソースをカスタマイズする方法について説明します。
Ververica Flink リアルタイムタスクリソースのカスタマイズエントリ
Dataphin ホームページで、トップメニューバーに移動し、[開発] > [データ開発] を選択します。
データ [開発] ページのトップメニューバーで、[プロジェクト] を選択します。
左側のナビゲーションウィンドウで、[データ処理] > [スクリプトタスク] を選択します。次に、右側のコンピューティングタスクリストで、目的のタスクをクリックします。
選択したコンピューティングタスクタブで、右側のサイドバーにある [構成] をクリックして、構成パネルを開きます。
構成パネルで、[リアルタイムモード] タブを選択します。[リアルタイムモード] タブの [リソース構成] セクションで、[リソース構成タイプ] を [カスタム構成] に設定します。
カスタム構成を選択した後、[構成に移動] をクリックします。
手順
リソース構成ページにはトポロジー図が表示されます。各ボックスは個別に構成可能なコンピューティングタスクを表しています。各グループは、ネットワークデータ伝送を最小限に抑え、パフォーマンスを向上させるために、その中のノードを1台の マシン に配置できることを示しています。図の現在のリソース構成は、システムのデフォルトの推奨事項です。
アイコンを グループ の右上隅でクリックして、リソースを設定します。 [カスタム設定グループランタイムパラメーター] および [カスタム設定 StreamExecCalc ランタイムパラメーター] ダイアログボックスでパラメーターを設定します。カスタム構成グループランタイムパラメーター
パラメーター
説明
CPU
現在のノードの操作の CPU リソースを指定します。
ヒープメモリ
ヒープメモリとは、Java アプリケーションで使用されるメモリを指し、MB または GB 単位で測定されます。 JVM コマンドラインパラメーターで制御できます。Blink プログラムの場合、通常、キャッシュなど、オーバーヘッドにヒープメモリの一部が必要です。プログラムの規模に基づいてサイズを調整します。
ヒープメモリのサイズとそのコンポーネントは、JVM コマンドラインパラメーターで調整できます。通常、Blink プログラムでは、たとえばプログラムキャッシュにヒープメモリを割り当てるなど、特定量のヒープメモリオーバーヘッドが必要です。したがって、そのサイズはプログラムの規模に基づいて構成する必要があります。
オフヒープメモリ
オフヒープメモリのサイズを MB または GB 単位で設定します。
同時実行性
現在の SLOT ノードの下にあるすべての OPERATOR ノードの同時実行性をバッチ更新します。SLOT ノード[SLOT ノード] (最外層) の アイコンをクリックして、ポップアップダイアログボックスで同時実行性を構成します。1 から 32768 までの正の整数を受け入れます。空のままにすると、更新は実行されません。
1 から 32768 までの正の整数入力を受け入れます。空のままにすると、更新は実行されません。
説明注: SLOT ノードのみが同時実行性のバッチ変更をサポートしています。
カスタム構成 StreamExecCalc ランタイムパラメーター
パラメーター
説明
同時実行性
デフォルトの同時実行性は 1 です。0 より大きい整数、または自動推論の場合は -1 を入力します。
連鎖ポリシー
常に: 上流と下流の両方のオペレーターとの連鎖を確保します。
ヘッド: 現在のオペレーターはチェーンのヘッドノードとして機能し、上流のオペレーターとのリンクのみを解除し、下流のノードとのチェーンを維持します。
しない: このオペレーターは、上流または下流のオペレーターと連鎖しません。
オペレーターの状態の有効期限の設定
現在の OPERATOR ノードがステートフルの場合、各状態に個別の有効期限を設定できます。
有効期限は、日、時間、分、または秒単位で設定できます。
パラメーターの構成が完了したら、[OK] をクリックします。
構成後、ページの右上隅にある [保存] をクリックします。
重要システム推奨のリソース構成に戻すには、ページの右上隅にある [システム初期値にリセット] をクリックします。
さらに、リソース構成レコードを保存するオプションがあります。これを行うには、[リソース情報レコード] に続いて [現在の構成を新しいレコードとして保存] をクリックします。[リソースレコードの保存] ダイアログボックスで、[リソースレコード名] を入力し、[OK] をクリックします。
既存のリソース情報レコードに対して、次の操作を実行できます。
操作
説明
バージョン情報の表示
バージョン情報を表示するには、レコードの列の下にある [アクション]
アイコンをクリックします。レコードの有効化
レコードの列の下にある [アクション]
アイコンをクリックします。[プロンプト] ダイアログボックスで、[OK] をクリックします。
レコードの削除
レコードの列の下にある [アクション]
アイコンをクリックします。[プロンプト] ダイアログボックスで、[OK] をクリックします。