Flink metrics - Managed Service for Prometheus - Managed Service for Prometheus

Ölçüm türleri ve faturalama

Managed Service for Prometheus, yazılan veri hacmine veya raporlanan veri noktası sayısına göre faturalandırılır. Ölçümler iki kategoriye ayrılır:

Temel ölçümler — Alibaba Cloud Realtime Compute for Apache Flink üzerinden toplanan temel ölçümler, Managed Service for Prometheus'a raporlandığında veya yazıldığında ücretsizdir. Bu avantaj, kendi kendine yönetilen Flink gibi diğer Flink hizmetlerine uygulanmaz.
Özel ölçümler — Temel ölçümler dışındaki tüm ölçümler özel ölçümlerdir. Özel ölçümler 6 Ocak 2020 tarihinden itibaren ücretlendirilmektedir. Bu konudaki her tablonun Type sütunu, bir ölçümün ait olduğu kategoriyi belirtir. Temel ölçümler JobManager ve TaskManager JVM ile sistem kaynağı bölümlerinde yoğunlaşmıştır. Kalan bölümlerdeki ölçümler özel ölçümlerdir; bu nedenle iş sağlığı, gecikme süresi, aktarım hızı, checkpoint, durum, pencere ve CDC bağlayıcı verileri raporlandığında ücretlendirilir. İki JVM bölümü içinde, yanlarındaki ölçümler temel ölçüm olsa bile sekiz G1 çöp toplama ölçümü özel ölçümdür.

Ölçüm tablolarının okunması

Bu konudaki her ölçüm tablosu aynı beş sütunu kullanır:

Metric — Managed Service for Prometheus'a raporlandığı şekliyle ölçüm adı.
Description — Ölçümün neyi ölçtüğü.
Details — Değerin nasıl yorumlanacağı veya değer anormal göründüğünde neyin kontrol edileceği.
Unit — Ölçüm değerinin birimi. Bu konuda kullanılan değerler şunlardır: Count, Count/s, Bytes, Bytes/s, ms ve ns.
Type — Ölçüm kategorisi: Basic veya Custom. Bir hücredeki N/A değeri, bu konunun o hücre için bir değer sağlamadığını gösterir. Unit sütununda N/A olması, ölçüm için belgelenmiş bir birim bulunmadığı anlamına gelir.

Bazı ölçüm adları, ölçüm raporlandığında yerine gerçek değerlerin geldiği değişken segmentler içerir; bu nedenle tablodaki ad, bir zaman serisinin gerçek adı değildir. state_name ifadesi, ölçümün uygulandığı durumun adını temsil eder ve cdcns_schema_table ifadesi ise izlenen tablonun CDC ad alanını, şema adını ve tablo adını temsil eder. Bir ölçüm adını sorguda veya uyarı kuralında kullanmadan önce bu segmentleri gerçek değerlerle değiştirin.

İş sağlığı

Metric	Description	Details	Unit	Type
`flink_jobmanager_job_numRestarts`	Hatalardan kaynaklanan iş yeniden başlatma sayısı	İş hatalarından kaynaklanan yeniden başlatma sayısı. JobManager yük devretmeleri sayılmaz.	Count	Custom
`flink_jobmanager_job_uptime`	İş çalışma süresi	N/A	ms	Custom
`flink_jobmanager_numRunningJobs`	Çalışan iş sayısı	N/A	N/A	Custom
`flink_jobmanager_taskSlotsAvailable`	Kullanılabilir görev yuvası sayısı	N/A	N/A	Custom
`flink_jobmanager_taskSlotsTotal`	Toplam görev yuvası sayısı	N/A	N/A	Custom
`flink_jobmanager_numRegisteredTaskManagers`	Kayıtlı TaskManager sayısı	N/A	N/A	Custom

Gecikme süresi

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_currentEmitEventTimeLag`	Operatörün yayınladığı kayıtların olay zamanı gecikmesi	Yüksek bir değer, işin veri çekerken veya işlerken gecikme yaşıyor olabileceğini gösterir.	ms	Custom
`flink_taskmanager_job_task_operator_currentFetchEventTimeLag`	Operatörün çektiği kayıtların olay zamanı gecikmesi	Yüksek bir değer, işin veri çekerken gecikme yaşıyor olabileceğini gösterir.	ms	Custom
`flink_taskmanager_job_task_currentInputWatermark`	Her görev tarafından alınan en son su işareti zamanı	Görevin aldığı verilerin gecikmesini gösterir.	N/A	Custom
`flink_taskmanager_job_task_operator_watermarkLag`	Operatörün su işareti gecikmesi	Alt görev düzeyinde iş gecikmesini gösterir.	ms	Custom

Aktarım hızı

Kayıt aktarım hızı

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_numRecordsIn`	Görevin aldığı toplam kayıt sayısı	Bir görevin numRecordsIn değeri uzun süre artmazsa, yukarı akış veriyi düşürmüş ve iletememiş olabilir. Bu durumda yukarı akış verilerini kontrol edin.	Count	Custom
`flink_taskmanager_job_task_numRecordsOut`	Görevin çıktığı toplam kayıt sayısı	Bir görevin numRecordsOut değeri uzun süre artmazsa, iş kodundaki bir mantık hatası veriyi düşürerek iletilmemesine neden olmuş olabilir. Bu durumda iş kodu mantığını kontrol edin.	Count	Custom
`flink_taskmanager_job_task_operator_numRecordsIn`	Operatörün aldığı toplam kayıt sayısı	Bir operatörün numRecordsIn değeri uzun süre artmazsa, yukarı akış veriyi düşürmüş ve iletememiş olabilir. Bu durumda yukarı akış verilerini kontrol edin.	Count	Custom
`flink_taskmanager_job_task_operator_numRecordsOut`	Operatörün çıktığı toplam kayıt sayısı	Bir operatörün numRecordsOut değeri uzun süre artmazsa, iş kodundaki bir mantık hatası veriyi düşürerek iletilmemesine neden olmuş olabilir. Bu durumda iş kodu mantığını kontrol edin.	Count	Custom
`flink_taskmanager_job_task_operator_source_numRecordsIn`	Yalnızca kaynak operatörünün giriş kayıtları	Yukarı akış veri girişini kontrol edin.	Count	Custom
`flink_taskmanager_job_task_operator_sink_numRecordsOut`	Sink tarafından çıktılan toplam kayıt sayısı	Aşağı akış veri çıkışını kontrol edin.	Count	Custom
`flink_taskmanager_job_task_numRecordsInPerSecond`	Görevin saniyede aldığı kayıt sayısı	Bir görevin işleme hızını izlemeniz gereken senaryolar için uygundur. Örneğin, görevin işleme hızının beklenen düzeye ulaşıp ulaşmadığını ve farklı giriş yükleri altında performansın nasıl değiştiğini kontrol edebilirsiniz.	Count/s	Custom
`flink_taskmanager_job_task_numRecordsOutPerSecond`	Görevin saniyede çıktığı kayıt sayısı	Bir görevin çıktı hızını izlemeniz gereken senaryolar için uygundur. Örneğin, görevin çıktı hızının beklenen düzeye ulaşıp ulaşmadığını ve farklı çıktı yükleri altında performansın nasıl değiştiğini kontrol edebilirsiniz.	Count/s	Custom
`flink_taskmanager_job_task_operator_numRecordsInPerSecond`	Operatörün saniyede aldığı kayıt sayısı	Bir operatörün işleme hızını izlemeniz gereken senaryolar için uygundur. Örneğin, operatörün işleme hızının beklenen düzeye ulaşıp ulaşmadığını ve farklı giriş yükleri altında performansın nasıl değiştiğini kontrol edebilirsiniz.	Count/s	Custom
`flink_taskmanager_job_task_operator_numRecordsOutPerSecond`	Operatörün saniyede çıktığı kayıt sayısı	Bir operatörün çıktı hızını izlemeniz gereken senaryolar için uygundur. Örneğin, operatörün çıktı hızının beklenen düzeye ulaşıp ulaşmadığını ve farklı çıktı yükleri altında performansın nasıl değiştiğini kontrol edebilirsiniz.	Count/s	Custom
`flink_taskmanager_job_task_operator_source_numRecordsInPerSecond`	Kaynak tarafından saniyede girilen kayıt sayısı	Her veri kaynağının oluşum oranını anlamanız ve her veri kaynağı tarafından saniyede oluşturulan kayıt sayısını ölçmeniz gereken senaryolar için uygundur. Bir veri akışındaki farklı veri kaynakları farklı sayıda kayıt üretebilir, bu nedenle bu ölçüm veri akışını daha iyi performans için ayarlamanıza yardımcı olur. Bu ölçüm izleme ve uyarı için de kullanılır. 0 değeri, yukarı akışın veriyi düşürdüğünü gösterebilir. Yukarı akış verileri tüketilmediği için çıktının engellenip engellenmediğini kontrol edin.	Count/s	Custom
`flink_taskmanager_job_task_operator_sink_numRecordsOutPerSecond`	Sink tarafından saniyede çıktılan kayıt sayısı	Her sink'in çıktı hızını anlamanız ve her sink tarafından saniyede çıktılan kayıt sayısını ölçmeniz gereken senaryolar için uygundur. Bir veri akışındaki farklı sink'ler farklı sayıda kayıt çıktılayabilir, bu nedenle bu ölçüm veri akışını daha iyi performans için ayarlamanıza yardımcı olur. Bu ölçüm izleme ve uyarı için de kullanılır. 0 değeri, iş kodundaki bir mantık hatasının tüm veriyi filtrelediğini gösterebilir. Bu durumda iş kodu mantığını kontrol edin.	Count/s	Custom

Bayt aktarım hızı

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_numBytesIn`	Operatörün aldığı toplam bayt sayısı	İşin trafiğini gözlemlemek için yukarı akış throughput girişini kontrol edin.	Bytes	Custom
`flink_taskmanager_job_task_operator_numBytesOut`	Operatörün çıktığı toplam bayt sayısı	İşin trafiğini gözlemlemek için aşağı akış throughput çıkışını kontrol edin.	Bytes	Custom
`flink_taskmanager_job_task_operator_numBytesInPerSecond`	Operatörün saniyede aldığı bayt sayısı	N/A	Bytes/s	Custom
`flink_taskmanager_job_task_operator_numBytesOutPerSecond`	Operatörün saniyede çıktığı bayt sayısı	İşin trafiğini gözlemlemek için aşağı akış throughput çıkışını kontrol edin.	Bytes/s	Custom
`flink_taskmanager_job_task_numBytesInLocalPerSecond`	Görevin yerel kaynaklardan saniyede okuduğu bayt sayısı	İşin trafiğini gözlemlemek için yukarı akış giriş hızını kontrol edin.	Bytes/s	Custom
`flink_taskmanager_job_task_numBytesInRemotePerSecond`	Görevin uzak kaynaklardan saniyede okuduğu bayt sayısı	N/A	Bytes/s	Custom
`flink_taskmanager_job_task_numBytesOutPerSecond`	Görevin saniyede çıktığı bayt sayısı	N/A	Bytes/s	Custom

Ağ arabellekleri

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_numBuffersInLocalPerSecond`	Saniyede tüketilen yerel veri arabelleği sayısı	Yüksek bir değer, görevler arasında sık yerel iletişim olduğunu, yani aynı düğüm üzerinde iletişim bulunduğunu gösterir.	Count/s	Custom
`flink_taskmanager_job_task_numBuffersInRemotePerSecond`	Uzak TaskManager'lardan saniyede alınan arabellek sayısı	TaskManager'lar arası iletişimin sıklığını yansıtır.	Count/s	Custom
`flink_taskmanager_job_task_numBuffersOutPerSecond`	Diğer görevlere saniyede gönderilen arabellek sayısı	Görevlerin çıktı baskısını ve ağ bant genişliği kullanımını gösterir.	Count/s	Custom

Kaynak ve sink

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_pendingRecords`	Kaynaktan henüz okunmamış kayıt sayısı	Dış sistemde kaynak tarafından henüz çekilmemiş olan kayıt sayısı.	Count	Custom
`flink_taskmanager_job_task_operator_sourceIdleTime`	Kaynağın veri işlemediği süre	Kaynağın boşta olup olmadığını gösterir. Yüksek bir değer, dış sistemdeki veri oluşum oranının düşük olduğunu gösterir.	ms	Custom
`flink_taskmanager_job_task_operator_currentSendTime`	En son kaydın gönderilmesi için geçen süre	N/A	ms	Custom

Checkpoint'ler

Metric	Description	Details	Unit	Type
`flink_jobmanager_job_totalNumberOfCheckpoints`	Toplam checkpoint sayısı	N/A	Count	Custom
`flink_jobmanager_job_numberOfFailedCheckpoints`	Başarısız checkpoint sayısı	N/A	Count	Custom
`flink_jobmanager_job_numberOfCompletedCheckpoints`	Tamamlanan checkpoint sayısı	N/A	Count	Custom
`flink_jobmanager_job_numberOfInProgressCheckpoints`	Devam eden checkpoint sayısı	N/A	Count	Custom
`flink_jobmanager_job_lastCheckpointDuration`	En son checkpoint'in süresi	Bir checkpoint çok uzun sürerse veya zaman aşımına uğrarsa, bunun nedeni aşırı büyük bir durum, geçici bir ağ sorunu, hizalanmamış engeller veya veri geri baskısı olabilir.	ms	Custom
`flink_jobmanager_job_lastCheckpointSize`	En son checkpoint'in boyutu	En son gerçekten yüklenen checkpoint'in boyutu. Checkpoint oluşturma işlemi bir darboğaz olduğunda checkpoint performansını analiz etmek için bu ölçümü kullanın.	Bytes	Custom

Durum

Durum ölçümleri, durum türüne göre gruplandırılmış tek bir durum işleminin maksimum gecikme süresini ve GeminiDB'nin depoladığı durum verilerinin boyutunu bildirir. Bir durum gecikmesi ölçüm adında, izlemek istediğiniz durumun adıyla state_name ifadesini değiştirin. Her gecikme ölçümü, adının tanımladığı durum işleminin performansını gösterir; bu nedenle bu ölçümler için Details sütunu N/A değerini içerir.

Genel

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_stateClearLatency`	Tek bir durum temizleme işleminin maksimum gecikme süresi	N/A	ns	Custom

Value state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_valueStateGetLatency`	Tek bir value state erişiminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_valueStateUpdateLatency`	Tek bir value state güncellemesinin maksimum gecikme süresi	N/A	ns	Custom

Aggregating state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_aggregatingStateGetLatency`	Tek bir aggregating state erişiminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_aggregatingStateAddLatency`	Tek bir aggregating state ekleme işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_aggregatingStateMergeNamespacesLatency`	Tek bir aggregating state ad alanı birleştirme işleminin maksimum gecikme süresi	N/A	ns	Custom

Reducing state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_reducingStateGetLatency`	Tek bir reducing state erişiminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_reducingStateAddLatency`	Tek bir reducing state ekleme işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_reducingStateMergeNamespacesLatency`	Tek bir reducing state ad alanı birleştirme işleminin maksimum gecikme süresi	N/A	ns	Custom

Map state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_mapStateGetLatency`	Tek bir map state erişiminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStatePutLatency`	Tek bir map state put işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStatePutAllLatency`	Tek bir map state put all işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateRemoveLatency`	Tek bir map state remove işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateContainsLatency`	Tek bir map state contains işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateEntriesInitLatency`	Tek bir map state entries init işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateKeysInitLatency`	Tek bir map state keys init işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateValuesInitLatency`	Tek bir map state values init işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateIteratorInitLatency`	Tek bir map state iterator init işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateIsEmptyLatency`	Tek bir map state boşluk kontrolünün maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateIteratorHasNextLatency`	Tek bir map state iterator hasNext işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateIteratorNextLatency`	Tek bir map state iterator next işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_mapStateIteratorRemoveLatency`	Tek bir map state iterator remove işleminin maksimum gecikme süresi	N/A	ns	Custom

List state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_listStateGetLatency`	Tek bir list state erişiminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_listStateAddLatency`	Tek bir list state ekleme işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_listStateAddAllLatency`	Tek bir list state add all işleminin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_listStateUpdateLatency`	Tek bir list state güncellemesinin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_listStateMergeNamespacesLatency`	Tek bir list state ad alanı birleştirme işleminin maksimum gecikme süresi	N/A	ns	Custom

Sorted map state

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_state_name_sortedMapStateFirstEntryLatency`	Sıralı bir map state'in ilk girdisine tek erişimin maksimum gecikme süresi	N/A	ns	Custom
`flink_taskmanager_job_task_operator_state_name_sortedMapStateLastEntryLatency`	Sıralı bir map state'in son girdisine tek erişimin maksimum gecikme süresi	N/A	ns	Custom

GeminiDB durum depolama

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_geminiDB_total_size`	Durum verilerinin boyutu	Bu ölçümü izleyerek, durum darboğazlarının doğrudan veya önceden meydana gelebileceği düğümleri tespit edebilir ve TTL'nin etkili olup olmadığını belirleyebilirsiniz.	Bytes	Custom
`flink_taskmanager_job_task_operator_geminiDB_total_filesize`	Durum veri dosyalarının boyutu	Bu ölçümü izleyerek, durum tarafından ne kadar yerel disk alanı kaplandığını kontrol edebilir, kullanım yüksek olduğunda önceden önlem alabilir ve yetersiz yerel disk alanının aşırı büyük durum verilerinden kaynaklanıp kaynaklanmadığını belirleyebilirsiniz.	Bytes	Custom

Pencere ölçümleri

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_numLateRecordsDropped`	Pencere gecikmesi nedeniyle düşürülen toplam kayıt sayısı	N/A	Count	Custom
`flink_taskmanager_job_task_operator_lateRecordsDroppedRate`	Pencere gecikmesi nedeniyle kayıtların düşürülme oranı	N/A	N/A	Custom

CDC bağlayıcı ölçümleri

Change data capture (CDC) bağlayıcı ölçümleri, tam verilerin işlendiği snapshot aşamasını ve artımlı verilerin işlendiği binary logging (binlog) aşamasını takip eder. Aşağıdaki tablolar bu ölçümleri, işin şu anda bulunduğu aşamaya, snapshot aşamasının ilerlemesine, okunan veri hacmine ve artımlı aşamada işlenen DML ve DDL ifadelerine göre gruplandırır.

Bir ölçüm adında, izlemek istediğiniz tablonun CDC ad alanı, şema adı ve tablo adıyla cdcns_schema_table ifadesini değiştirin. Adında bu segment bulunan ölçümler, tek bir tablo için değerler bildirir. Adında bu segment bulunmayan ölçümler ise tüm iş için değerler bildirir.

Aşama göstergeleri

Metric	Description	Details	Unit	Type
`flink_jobmanager_job_operator_coordinator_enumerator_isSnapshotting`	İşin tam verilerin işlendiği aşamada olup olmadığı	İşin hala snapshot aşamasında olup olmadığını belirleyin.	N/A	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_isBinlogReading`	İşin artımlı verilerin işlendiği aşamada olup olmadığı	İşin binlog aşamasına girip girmediğini belirleyin.	N/A	Custom

Snapshot ilerlemesi

Metric	Description	Details	Unit	Type
`flink_jobmanager_job_operator_coordinator_enumerator_numTablesRemaining`	Snapshot aşamasında henüz işlenmemiş tablo sayısı	Hala işlenmeyi bekleyen tablo sayısını görüntüleyin.	Count	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_numTablesSnapshotted`	Snapshot'u tamamlanmış tablo sayısı	İşlenmiş tablo sayısını görüntüleyin.	Count	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_numSnapshotSplitsProcessed`	Tüm iş için snapshot aşamasında işlenmiş parça sayısı	Tüm tablolardaki işlenmiş parça sayısını görüntüleyin.	Count	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_cdcns_schema_table_numSnapshotSplitsProcessed`	Tek bir tablo için snapshot aşamasında işlenmiş parça sayısı	Belirtilen tablo için işlenmiş parça sayısını görüntüleyin.	Count	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_numSnapshotSplitsRemaining`	Tüm iş için snapshot aşamasında işlenmeyi bekleyen parça sayısı	Tüm tablolardaki işlenmemiş parça sayısını görüntüleyin.	Count	Custom
`flink_jobmanager_job_operator_coordinator_enumerator_cdcns_schema_table_numSnapshotSplitsRemaining`	Tek bir tablo için snapshot aşamasında işlenmeyi bekleyen parça sayısı	Belirtilen tablo için işlenmemiş parça sayısını görüntüleyin.	Count	Custom

Veri hacmi

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_currentReadTimestampMs`	Okunan en son veri kaydının zaman damgası	En son binlog verisinin zaman damgasını görüntüleyin.	ms	Custom
`flink_taskmanager_job_task_operator_numSnapshotRecords`	Snapshot aşamasında işlenmiş kayıt sayısı	Snapshot aşamasında işlenmiş veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_cdcns_schema_table_numRecordsIn`	Her tablo için okunan kayıt sayısı	Her tablo için işlenmiş toplam veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_cdcns_schema_table_numSnapshotRecords`	Her tablo için snapshot aşamasında işlenmiş kayıt sayısı	Her tablo için snapshot aşamasında işlenmiş veri hacmini görüntüleyin.	Count	Custom

Artımlı aşama DML ve DDL

Metric	Description	Details	Unit	Type
`flink_taskmanager_job_task_operator_cdcns_schema_table_numInsertDMLRecords`	Artımlı aşamada her tablo için işlenen INSERT DML ifadelerinin sayısı	Her tablo için INSERT ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_cdcns_schema_table_numUpdateDMLRecords`	Artımlı aşamada her tablo için işlenen UPDATE DML ifadelerinin sayısı	Her tablo için UPDATE ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_cdcns_schema_table_numDeleteDMLRecords`	Artımlı aşamada her tablo için işlenen DELETE DML ifadelerinin sayısı	Her tablo için DELETE ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_cdcns_schema_table_numDDLRecords`	Artımlı aşamada her tablo için işlenen DDL ifadelerinin sayısı	Her tablo için DDL ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_numInsertDMLRecords`	Artımlı aşamada işlenen INSERT DML ifadelerinin sayısı	INSERT ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_numUpdateDMLRecords`	Artımlı aşamada işlenen UPDATE DML ifadelerinin sayısı	UPDATE ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_numDeleteDMLRecords`	Artımlı aşamada işlenen DELETE DML ifadelerinin sayısı	DELETE ifadelerinin veri hacmini görüntüleyin.	Count	Custom
`flink_taskmanager_job_task_operator_numDDLRecords`	Artımlı aşamada işlenen DDL ifadelerinin sayısı	DDL ifadelerinin veri hacmini görüntüleyin.	Count	Custom

JobManager JVM ve sistem kaynakları

CPU

Metric	Description	Details	Unit	Type
`flink_jobmanager_Status_JVM_CPU_Load`	Tek bir JobManager CPU yükü	Bu değer uzun süre %100'ün üzerinde kalırsa CPU yoğundur ve yük yüksektir. Bu durum sistem performansını etkileyebilir ve sistemin takılmasına veya yanıt süresinin aşırı uzamasına neden olabilir.	N/A	Basic
`flink_jobmanager_Status_ProcessTree_CPU_Usage`	Tek bir JobManager CPU kullanımı	Bu değer, Flink'in ne kadar CPU zamanı tükettiğini yansıtır. 1 CPU çekirdeği tamamen kullanıldığında değer %100, 4 CPU çekirdeği tamamen kullanıldığında %400 olur. Bu değer uzun süre %100'ün üzerinde kalırsa CPU çok yoğundur. Yük yüksek ancak CPU kullanımı düşükse, sık okuma ve yazma işlemleri çok sayıda işlemi kesintiye uğramayan uyku durumunda bırakmış olabilir.	N/A	Basic

Bellek

Metric	Description	Details	Unit	Type
`flink_jobmanager_Status_JVM_Memory_Heap_Used`	JobManager yığın belleği	N/A	Bytes	Basic
`flink_jobmanager_Status_JVM_Memory_Heap_Committed`	JobManager tarafından tahsis edilen yığın bellek	N/A	Bytes	Basic
`flink_jobmanager_Status_JVM_Memory_Heap_Max`	JobManager maksimum yığın belleği	N/A	Bytes	Basic
`flink_jobmanager_Status_JVM_Memory_NonHeap_Used`	JobManager yığın dışı belleği	N/A	Bytes	Basic
`flink_jobmanager_Status_JVM_Memory_NonHeap_Committed`	JobManager tarafından tahsis edilen yığın dışı bellek	N/A	Bytes	Basic
`flink_jobmanager_Status_JVM_Memory_NonHeap_Max`	JobManager maksimum yığın dışı belleği	N/A	Bytes	Basic

İş parçacıkları

Metric	Description	Details	Unit	Type
`flink_jobmanager_Status_JVM_Threads_Count`	JobManager iş parçacığı sayısı	Çok fazla JobManager iş parçacığı aşırı bellek alanı kaplar ve iş kararlılığını azaltır.	Count	Basic

Çöp toplama

Aşağıdaki tablodaki G1 çöp toplayıcı ölçümleri özel ölçümlerdir. Diğer JobManager çöp toplama ölçümleri temel ölçümlerdir.

Metric	Description	Details	Unit	Type
`flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Count`	JobManager GC sayısı	Çok fazla GC aşırı bellek alanı kaplar ve iş performansını etkiler. Bu ölçüm, işleri tanılamanıza ve iş düzeyindeki arızaları gidermenize yardımcı olur.	Count	Basic
`flink_jobmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Count`	JobManager genç nesil GC sayısı (G1 çöp toplayıcı)	N/A	Count	Custom
`flink_jobmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Count`	JobManager eski nesil GC sayısı (G1 çöp toplayıcı)	N/A	Count	Custom
`flink_jobmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Time`	JobManager genç nesil GC süresi (G1 çöp toplayıcı)	N/A	ms	Custom
`flink_jobmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Time`	JobManager eski nesil GC süresi (G1 çöp toplayıcı)	N/A	ms	Custom
`flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count`	JobManager CMS çöp toplayıcı tarafından gerçekleştirilen koleksiyon sayısı	N/A	Count	Basic
`flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Time`	Her JobManager GC'nin süresi	Uzun GC'ler aşırı bellek alanı kaplar ve iş performansını etkiler. Bu ölçüm, işleri tanılamanıza ve iş düzeyindeki arızaları gidermenize yardımcı olur.	ms	Basic
`flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time`	JobManager CMS çöp toplayıcı tarafından gerçekleştirilen koleksiyonların tükettiği süre	N/A	ms	Basic

Sınıf yükleme

Metric	Description	Details	Unit	Type
`flink_jobmanager_Status_JVM_ClassLoader_ClassesLoaded`	JobManager'ı barındıran JVM oluşturulduktan sonra yüklenen toplam sınıf sayısı	JobManager'ı barındıran JVM oluşturulduktan sonra yüklenen toplam sınıf sayısı çok fazlaysa, aşırı bellek alanı kaplanır ve iş performansı etkilenir.	N/A	Basic
`flink_jobmanager_Status_JVM_ClassLoader_ClassesUnloaded`	JobManager'ı barındıran JVM oluşturulduktan sonra kaldırılan toplam sınıf sayısı	JobManager'ı barındıran JVM oluşturulduktan sonra kaldırılan toplam sınıf sayısı çok fazlaysa, aşırı bellek alanı kaplanır ve iş performansı etkilenir.	N/A	Basic

TaskManager JVM ve sistem kaynakları

CPU

Metric	Description	Details	Unit	Type
`flink_taskmanager_Status_JVM_CPU_Load`	Tek bir TaskManager CPU yükü	CPU'nun belirli bir süre boyunca işlediği ve CPU için bekleyen işlemlerin toplamıdır; genellikle CPU'nun ne kadar meşgul olduğu olarak anlaşılır. CPU'nun ne kadar meşgul olduğu CPU çekirdeklerinin sayısına bağlıdır. Flink'te CPU yükü değeri `CPU Usage / Number of CPU cores` şeklindedir. `flink_taskmanager_Status_JVM_CPU_Load` değeri CPU yükü değerinden büyükse, CPU işlemesi engelleniyor olabilir.	N/A	Basic
`flink_taskmanager_Status_ProcessTree_CPU_Usage`	Tek bir TaskManager CPU kullanımı	Bu değer, Flink'in ne kadar CPU zamanı tükettiğini yansıtır. 1 CPU çekirdeği tamamen kullanıldığında değer %100, 4 CPU çekirdeği tamamen kullanıldığında %400 olur. Bu değer uzun süre %100'ün üzerinde kalırsa CPU çok yoğundur. Yük yüksek ancak CPU kullanımı düşükse, sık okuma ve yazma işlemleri çok sayıda işlemi kesintiye uğramayan uyku durumunda bırakmış olabilir.	N/A	Basic

Bellek

Metric	Description	Details	Unit	Type
`flink_taskmanager_Status_JVM_Memory_Heap_Used`	TaskManager yığın belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_JVM_Memory_Heap_Committed`	TaskManager tahsis edilmiş yığın belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_JVM_Memory_Heap_Max`	TaskManager maksimum yığın belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_JVM_Memory_NonHeap_Used`	TaskManager yığın dışı belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_JVM_Memory_NonHeap_Committed`	TaskManager tahsis edilmiş yığın dışı belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_JVM_Memory_NonHeap_Max`	TaskManager maksimum yığın dışı belleği	N/A	Bytes	Basic
`flink_taskmanager_Status_ProcessTree_Memory_RSS`	Linux aracılığıyla elde edilen tüm sürecin belleği	Süreç belleğindeki değişiklikleri görüntüleyin.	Bytes	Basic

İş parçacıkları

Metric	Description	Details	Unit	Type
`flink_taskmanager_Status_JVM_Threads_Count`	TaskManager iş parçacığı sayısı	Çok fazla TaskManager iş parçacığı aşırı bellek kaplar ve iş kararlılığını azaltır.	Count	Basic

Çöp toplama

Aşağıdaki tablodaki G1 çöp toplayıcı ölçümleri özel ölçümlerdir. Diğer TaskManager çöp toplama ölçümleri temel ölçümlerdir.

Metric	Description	Details	Unit	Type
`flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Count`	TaskManager GC sayısı	Çok fazla GC aşırı bellek alanı kaplar ve iş performansını etkiler. Bu ölçüm, işleri tanılamanıza ve görev düzeyindeki arızaları gidermenize yardımcı olur.	Count	Basic
`flink_taskmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Count`	TaskManager genç nesil GC sayısı (G1 çöp toplayıcı)	N/A	Count	Custom
`flink_taskmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Count`	TaskManager eski nesil GC sayısı (G1 çöp toplayıcı)	N/A	Count	Custom
`flink_taskmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Time`	TaskManager genç nesil GC süresi (G1 çöp toplayıcı)	N/A	ms	Custom
`flink_taskmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Time`	TaskManager eski nesil GC süresi (G1 çöp toplayıcı)	N/A	ms	Custom
`flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count`	TaskManager CMS çöp toplayıcı tarafından gerçekleştirilen koleksiyon sayısı	N/A	Count	Basic
`flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Time`	Her TaskManager GC'nin süresi	Uzun GC'ler aşırı bellek alanı kaplar ve iş performansını etkiler. Bu ölçüm, işleri tanılamanıza ve görev düzeyindeki arızaları gidermenize yardımcı olur.	ms	Basic
`flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time`	TaskManager CMS çöp toplayıcı tarafından gerçekleştirilen koleksiyonların tükettiği süre	N/A	ms	Basic

Sınıf yükleme

Metric	Description	Details	Unit	Type
`flink_taskmanager_Status_JVM_ClassLoader_ClassesLoaded`	TaskManager'ı barındıran JVM oluşturulduktan sonra yüklenen toplam sınıf sayısı	TaskManager'ı barındıran JVM oluşturulduktan sonra yüklenen toplam sınıf sayısı çok fazlaysa, aşırı bellek alanı kaplanır ve iş performansı etkilenir.	N/A	Basic
`flink_taskmanager_Status_JVM_ClassLoader_ClassesUnloaded`	TaskManager'ı barındıran JVM oluşturulduktan sonra kaldırılan toplam sınıf sayısı	TaskManager'ı barındıran JVM oluşturulduktan sonra kaldırılan toplam sınıf sayısı çok fazlaysa, aşırı bellek alanı kaplanır ve iş performansı etkilenir.	N/A	Basic

Ortak ölçüm etiketleri

Flink ölçümleri genellikle aşağıdaki etiketleri taşır. Ölçüm verilerini proje, dağıtım veya işe göre filtrelemek ve toplamak için bunları kullanın.

Label	Description
`vvpNamespace`	Projenin ad alanı.
`deploymentName`	Dağıtımın adı.
`deploymentId`	Dağıtımın ID'si.
`jobId`	İşin ID'si.

Referanslar

Aşağıdaki konular ilgili ölçüm kümelerini ve ölçüm yönetimi seçeneklerini kapsamaktadır.

ARMS'deki Application Monitoring ölçümlerini görüntülemek için bkz. Application Monitoring ölçümleri.

Atılan ölçümleri yapılandırma