Realtime Compute for Apache Flink:ジョブのインテリジェント診断の実行

制限事項

デプロイメントのインテリジェント診断は、ストリーミングデプロイメントでのみサポートされています。バッチデプロイメントはサポートされていません。

仕組み

Flink Advisor は、デプロイメントの健全性を継続的に評価します。ヘルススコアは 100 から始まり、過去 30 分間に検出されたリスクの数と重大度に基づいて減点されます。

スコアは、デプロイメントリストに色分けされたバッジとして表示されます：

下書きの例外ログの診断

このワークフローは、デプロイメントを公開する前に SQL エラーを診断するために使用します。

1. Realtime Compute for Apache Flink コンソールにログインします。管理対象のワークスペースを見つけ、[Actions] 列の [Console] をクリックします。

2. 左側メニューで、[Development] > [ETL] を選択します。下書きを作成し、SQL ステートメントを記述して、[Validate] をクリックします。

3. SQL Editor ページの下部で、エラーの詳細、考えられる原因、および最適化案を確認します。

   たとえば、[Deep Check] セクションには、チェックステータス (「SQL syntax and network connectivity check failed」など) と詳細なエラーメッセージを含む赤色のエラーアイコンが表示されます。[Analysis Result] セクションには、考えられる原因 (「The table or view referenced in the SQL statement does not exist」など) と推奨される解決策 (「Verify that the table or view name has been created」など) が一覧表示されます。ページの最下部には、折りたたみ可能な [SQL Optimization] セクションが表示されます。

   構文チェックの結果から原因を特定できない場合は、関連するログを選択し、[Search in Documentation] をクリックして関連情報を見つけてください。

デプロイメントの例外ログの診断

このワークフローは、実行中または失敗したデプロイメントのログレベルの例外を調査するために使用します。

1. Realtime Compute for Apache Flink コンソールにログインします。管理対象のワークスペースを見つけ、[Actions] 列の [Console] をクリックします。

2. 左側メニューで、[O&M] > [Deployments] を選択します。調査対象のデプロイメントの名前をクリックします。

3. [Logs] タブをクリックします。左側のペインで、[Logs]、[Startup Logs]、または [JM Exceptions] をクリックして、関連するログを表示します。

   メインエリアには例外のスタックトレースが表示されます。その下には、[Analysis based on current logs] セクションに、考えられる原因と推奨される解決策が一覧表示されます。最下部には、[Exception History] テーブルに、初回発生時刻、名前、例外タイプ、発生回数とともに過去の例外が表示されます。

ログタイプの詳細については、「デプロイメントの起動ログと操作ログの表示」をご参照ください。例外ログを調査するには、「デプロイメントの例外ログの表示」をご参照ください。履歴レコードにアクセスするには、「履歴デプロイメントのログの表示」をご参照ください。

異常なデプロイメントに対するインテリジェント診断の実行

このワークフローは、デプロイメントが異常な状態にあり、根本原因を特定する必要がある場合に使用します。

1. 次のいずれかの方法で [Diagnosis] タブに移動します：

   • デプロイメントリストでデプロイメントを見つけ、[Health] 列のスコアをクリックします。

   • デプロイメント名をクリックし、[Diagnosis] タブをクリックします。

   [Diagnosis] ページでは、ヘルススコア (たとえば 99) と診断時間を確認できます。[Diagnose] をクリックすると、診断チェックが実行されます。結果には、チェックされた項目の総数 (たとえば 5) が表示され、[Resource Analysis] などのカテゴリは注意を要しますが、[Startup Analysis]、[Deployment Analysis]、[State Analysis]、[Exception Analysis] は診断チェックに合格しています。

2. [Diagnose] をクリックします。診断項目と修正手順の完全なリストについては、「Flink Advisor の診断項目」をご参照ください。

3. 診断結果と最適化案を確認します。提案を適用するには、その横にある [Apply] をクリックします。

Flink Advisor の診断項目

診断項目は 2 つのカテゴリに分類されます：

• [例外]：デプロイメントの実行に影響があります。直ちに対応が必要です。

• リスク：デプロイメントは現在実行中ですが、潜在的な問題が検出されています。将来の障害を防ぐために、事前に対応してください。

次のステップ

• 実行中のデプロイメントの JobManager と TaskManager のパフォーマンスメトリクスを監視します。詳細については、「デプロイメントのパフォーマンスの監視」をご参照ください。

• 自動チューニングを設定して、システムが自動的またはスケジュールに従ってリソースを再設定できるようにします。詳細については、「自動パフォーマンステューニングの有効化」をご参照ください。

• デプロイメント設定と SQL ロジックをチューニングして、Flink SQL デプロイメントを最適化します。詳細については、「Flink SQL の最適化」をご参照ください。