Bu konu, Realtime Compute for Apache Flink'teki geçmiş işlerin günlüklerini Logs sekmesinden, Object Storage Service (OSS) üzerinden ve Simple Log Service (SLS) aracılığıyla olmak üzere üç farklı konumda nasıl görüntüleyeceğinizi açıklar.
Arka plan
Aşağıdaki senaryolarda geçmiş iş günlüklerini görüntülemeniz gerekebilir:
Geçmiş bir işin çalışma günlüklerini görüntülemek, aramak ve analiz etmek istiyorsunuz. Sistem varsayılan olarak en son 5 MB'lık çalışma günlüğünü saklar.
Flink kullanıcı arayüzüne erişilemediğinde sorunları gidermek için JobManager günlüklerini kontrol etmeniz gerekir.
Bu konuda geçmiş iş günlüklerini görüntülemenin üç yolu açıklanmaktadır:
Ön koşullar
Geçmiş iş günlüklerini Logs sekmesinde görüntülemek için günlük arşivlemenin etkinleştirildiğinden emin olun. Bu özellik varsayılan olarak etkindir ve arşivlenen günlükler 7 gün boyunca saklanır. Bir Flink dağıtımının Configuration sekmesinde Logging bölümünü genişletin, Log Archiving anahtarını açın ve Archived Log Retention Period değerini (örneğin 7 gün) ayarlayın.
Geçmiş işlerin günlüklerini OSS veya SLS'te görüntülemek için bu işler için Realtime Compute for Apache Flink'te günlük çıkışını OSS veya SLS'e yapılandırmış olmanız gerekir. Daha fazla bilgi için bkz. İş günlüğü çıkışını yapılandırma.
Kullanım notları
-
Bir günlük dosyası belirtilen boyuta ulaştığında sistem dosyayı otomatik olarak arşivler ve saklama süresini aşan günlük dosyalarını periyodik olarak siler. Arşivlenen günlükler iş durdurulduktan sonra da saklanır. Bir dağıtım silindiğinde buna ilişkin günlükler de silinir.
NotKasım 2024'te yeni sürüm yayımlandıktan sonra, durdurulan işlerin arşivlenen günlükleri dahil olmak üzere Realtime Compute for Apache Flink konsolundaki tüm mevcut iş günlükleri saklama süreleri dolduğunda silinecektir.
Günlükler yalnızca bir TaskManager veya JobManager başarıyla başlatıldığında SLS veya OSS'e yazılır.
JobManager ve TaskManager'ların başlatılamaması durumunda günlükleri OSS'te bulamıyorsanız bizimle iletişime geçin.
-
Varsayılan olarak günlük yapılandırması her biri 5 MB boyutunda iki günlük dosyasını saklar. Bu değeri değiştirmemenizi öneririz; daha fazla günlük kapasitesine ihtiyacınız varsa günlükleri bunun yerine OSS'e aktarın. Configuration sekmesindeki Logging bölümünde varsayılan Log4j2 XML yapılandırması,
SizeBasedTriggeringPolicyöğesininsizedeğerini5 MBolarak ayarlar. Bir günlük dosyası bu boyuta ulaştığında devirme arşivlemesi tetiklenir.DefaultRolloverStrategyöğesininmaxniteliği1olarak ayarlanır.NotBu yapılandırmada belirtilen dosya sayısı, o anda yazılmakta olan dosyayı içermez. Örneğin,
maxdeğeri1olarak ayarlandığında en fazla iki dosya saklanır: bir aktif dosya ve bir arşivlenmiş dosya.
Logs sekmesinde günlükleri görüntüleyin
Realtime Compute for Apache Flink konsoluna giriş yapın.
Hedef çalışma alanının Actions sütununda Console seçeneğine tıklayın.
Sol gezinme bölmesinde seçeneklerini belirleyin.
Hedef dağıtımın adına tıklayın.
Logs sekmesine tıklayın.
-
Soldaki Logs sekmesinde Job açılan listesinden bir geçmiş iş seçin.
Sol panelde ayrıca Startup Logs ve Exceptions sekmeleri bulunur. Açılan liste işleri Running jobs ve Historical jobs olarak ayırır.
-
Görüntülemek için bir günlük seçin.
Job Manager veya Running Task Managers sekmesinde içeriğini görüntülemek için bir günlüğün adına tıklayın.
OSS'te günlükleri görüntüleyin
Object Storage Service (OSS) konsoluna giriş yapın.
Sol gezinme bölmesinde Buckets seçeneğine tıklayın.
Flink çalışma alanınız için yapılandırdığınız paketin name değerine tıklayın.
-
Artifacts bölümünde ilgili dizindeki günlük bilgilerini görüntüleyin.
Klasör
Açıklama
artifacts
Yüklenen JAR paketlerini depolar.
flink-jobs
Bu dizin bir Flink işi için kontrol noktalarını depolar.
flink-savepoints
Bu dizin, Realtime Compute for Apache Flink konsolunun sayfasında bir dağıtım için Create Savepoint seçeneğine tıkladığınızda oluşturulan savepoint dosyasını depolar.
logs
İşiniz için Logging Profile değerini OSS olarak ayarlarsanız bu dizin iş günlüklerini depolar.
Notlogs dizinindeki iş günlüklerinin depolama yolu logs/${workspace-id}/${job-id}/${instance-id} şeklindedir. İlgili iş için JobManager ve TaskManager günlüklerini bulmak amacıyla bu dizin yapısını kullanabilirsiniz.
SLS'te günlükleri görüntüleyin
Simple Log Service konsoluna giriş yapın.
Projects bölümünde hedef projeye tıklayın.
Logstores sekmesinde hedef Logstore'a tıklayın.
-
Bir sorgu girin, bir zaman aralığı seçin ve Search & Analyze seçeneğine tıklayın.
Daha fazla bilgi için bkz. Arama ve analize hızlı başlangıç.