Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。
本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
記錄對於生產應用程式了解錯誤和失敗非常重要。不過,記錄子系統需要收集日誌項目並將其轉寄至 CloudWatch Logs。雖然有些記錄正常且理想,但大量記錄可能會使服務多載,並導致 Flink 應用程式落後。記錄例外狀況和警告當然是一個好主意。但是您無法為 Flink 應用程式處理的每則訊息產生日誌訊息。Flink 針對高輸出量和低延遲進行最佳化,但記錄子系統沒有。如果確實需要為每個已處理的訊息產生日誌輸出,請在 Flink 應用程式內使用額外的資料串流,並使用適當的接收器將資料傳送到 Amazon S3 或 CloudWatch。請勿將 Java 記錄系統用於此目的。此外,Managed Service for Apache Flink 的 Debug Monitoring Log Level
設定會產生大量流量,從而會造成背壓。您只能在主動調查應用程式問題時使用它。
使用 CloudWatch Logs Insights 查詢日誌
CloudWatch Logs Insights 是一項功能強大的服務,可大規模查詢日誌。客戶應利用其功能快速搜尋日誌,以識別並減輕操作事件期間的錯誤。
下列查詢會在所有任務管理員記錄中尋找例外狀況,並根據其發生的時間排序。
fields @timestamp, @message
| filter isPresent(throwableInformation.0) or isPresent(throwableInformation) or @message like /(Error|Exception)/
| sort @timestamp desc
如需其他有用的查詢,請參閱範例查詢。