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] ページでは、[Health Score] (例：99) と診断時刻を確認できます。[Diagnose] をクリックして、診断チェックを実行します。結果には、チェックされた項目の総数 (例：5) が表示され、[Resource Analysis] などのカテゴリには注意が必要であることが示されますが、[Startup Analysis]、[Deployment Analysis]、[State Analysis]、および [Exception Analysis] は診断チェックに合格しています。

2. [Diagnose] をクリックします。Flink Advisor は、Flink 例外ログ用のさまざまなログリポジトリを提供します。診断項目と修復手順の完全なリストについては、「Flink Advisor 診断項目」をご参照ください。

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

Flink Advisor 診断項目

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

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

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

次のステップ

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

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

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