登入管理服務 - Managed Service for Apache Flink
使用記錄檔見解查詢 CloudWatch 記錄

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

登入管理服務

記錄對於生產應用程式了解錯誤和失敗非常重要。不過，記錄子系統需要收集記錄項目並將記錄項目轉寄至記錄 CloudWatch 檔。雖然有些記錄可正常且理想，但大量記錄可能會使服務超載，並造成 Flink 應用程式落後。記錄例外狀況和警告當然是一個好主意。但是您無法為 Flink 應用程式處理的每則訊息產生日誌訊息。Flink 針對高輸出量和低延遲進行最佳化，但記錄子系統沒有。如果確實需要為每個已處理的消息生成日誌輸出，請在 Flink 應用程序 DataStream 中使用另一個附加信息並使用適當的接收器將數據發送到 Amazon S3 或 CloudWatch。請勿將 Java 記錄系統用於此目的。此外，Managed Service for Apache Flink 的 Debug Monitoring Log Level 設定會產生大量流量，從而會造成背壓。您只能在主動調查應用程式問題時使用它。

查詢日誌記錄與 CloudWatch 日誌見解

CloudWatch 日誌深入解析是大規模查詢記錄的強大服務。客戶應利用其功能快速搜尋日誌，以識別並減輕操作事件期間的錯誤。

下列查詢會在所有任務管理員記錄中尋找例外狀況，並根據其發生的時間排序。

fields @timestamp, @message
| filter isPresent(throwableInformation.0) or isPresent(throwableInformation) or @message like /(Error|Exception)/
| sort @timestamp desc

如需其他有用的查詢，請參閱範例查詢。