リアルタイムモードでは、リアルタイムノードのプロパティを定義できます。これらのプロパティには、ノードリソース、時間パラメーター、チェックポイントなどが含まれます。このトピックでは、リアルタイムノードのリアルタイムモードを設定する方法について説明します。
リアルタイムモード設定へのアクセス
Dataphin のホームページで、トップメニューバーから [R&D] > [データ開発] を選択します。
トップメニューバーからプロジェクトを選択します。本番・開発モードの場合は、環境も選択する必要があります。
左側のメニューバーで、[データ処理] > [計算タスク] を選択し、リストから対象の計算タスクを選択します。
右側のサイドバーで [構成] をクリックします。構成パネルで、[リアルタイムモード] タブのパラメーターを設定します。
リアルタイムモードの構成
リアルタイムモード設定パネルで、次の表の説明に従って、リアルタイムノードのリソースおよび依存関係パラメーターを設定します。
構成項目 | 説明 |
リソース構成 |
|
変数の構成 | リアルタイムコンピューティングノードの変数パラメーターを設定するために使用します。詳細については、「リアルタイムモードの変数設定」をご参照ください。 |
[チェックポイント設定] | リアルタイムタスクのチェックポイントは、タスクの状態を永続ストレージに保存します。これにより、予期せぬクラッシュが発生した後でも、プログラムを再実行することでタスクをクラッシュ前の状態に復元できます。設定手順については、「リアルタイムモードのチェックポイント設定」をご参照ください。 |
状態構成 | State は、Flink リアルタイムタスクがデータの状態を維持および管理するために使用するメカニズムです。Flink State データの生存時間 (TTL) を適切に設定することで、リソース使用率、メモリ管理、データ整合性、およびフォールトトレランスを向上させることができます。設定手順については、「リアルタイムモードの State 設定」をご参照ください。 |
ランタイムパラメーター | リアルタイムノードを開発する際には、その動作とパフォーマンスを制御するために実行時パラメーターを設定する必要があることがよくあります。例としては、JobManager プロセスのメモリサイズや TaskManager のスロットタイムアウトなどがあります。 |
依存関係ファイル | リアルタイムノードがテキストファイル、Python ファイル、Jar ファイルなどの外部リソースファイルに依存している場合、対応するリソースファイルを Dataphin にアップロードし、ノードの依存ファイルとして追加することで、ノードが正常に実行されるようにできます。設定の詳細については、「リアルタイムモードでの依存ファイルの設定」をご参照ください。 |
依存関係 | リアルタイムノードの依存関係を設定すると、トラブルシューティングやテストの際に、データの上流および下流ノードを迅速に把握するのに役立ちます。詳細については、「リアルタイムモードでの依存関係の設定」をご参照ください。 |