Managed Service for Prometheus：Metrik Flink

Metrik

Definisi

Deskripsi

Satuan

Tipe

flink_jobmanager_job_numRestarts

Jumlah kali pekerjaan dimulai ulang ketika terjadi failover pekerjaan

Metrik ini menunjukkan jumlah kali pekerjaan dimulai ulang ketika terjadi failover pekerjaan. Jumlah kali pekerjaan dimulai ulang ketika terjadi failover JobManager tidak termasuk.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_currentEmitEventTimeLag

Latensi pemrosesan

Jika nilai metrik ini besar, mungkin terjadi penundaan dalam pekerjaan ketika sistem menarik atau memproses data.

Milidetik

Metrik kustom

flink_taskmanager_job_task_operator_currentFetchEventTimeLag

Latensi transmisi

Jika nilai metrik ini besar, mungkin terjadi penundaan dalam pekerjaan ketika sistem menarik data.

Milidetik

Metrik kustom

flink_taskmanager_job_task_numRecordsIn

Total jumlah catatan data masukan dari semua operator

Jika nilai metrik ini tidak bertambah untuk waktu yang lama pada sebuah operator, mungkin ada data yang hilang dari sumber. Oleh karena itu, data gagal dikirimkan. Dalam hal ini, Anda harus memeriksa data dari sumber.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_numRecordsOut

Total jumlah catatan keluaran

Jika nilai metrik ini tidak bertambah untuk waktu yang lama pada sebuah operator, mungkin terjadi kesalahan dalam logika kode pekerjaan dan data hilang. Oleh karena itu, data gagal dikirimkan. Dalam hal ini, Anda harus memeriksa logika kode pekerjaan.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numBytesIn

Total jumlah byte masukan

Metrik ini mengukur ukuran catatan data masukan dari sumber. Ini membantu mengamati throughput pekerjaan.

Byte

Metrik kustom

flink_taskmanager_job_task_operator_numBytesOut

Total jumlah byte keluaran

Metrik ini mengukur ukuran catatan data keluaran dari sumber. Ini membantu mengamati throughput pekerjaan.

Byte

Metrik kustom

flink_taskmanager_job_task_operator_numRecordsIn

Total jumlah catatan data masukan dari semua operator

Jika nilai metrik ini tidak bertambah untuk waktu yang lama pada sebuah operator, mungkin ada data yang hilang dari sumber. Oleh karena itu, data gagal dikirimkan. Dalam hal ini, Anda harus memeriksa data dari sumber.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numRecordsInPerSecond

Jumlah catatan data masukan per detik untuk aliran data

Metrik ini mengukur kecepatan pemrosesan keseluruhan dari aliran data.

Sebagai contoh, nilai metrik ini membantu menentukan apakah kecepatan pemrosesan keseluruhan dari aliran data memenuhi persyaratan yang diharapkan dan bagaimana kinerja pekerjaan berubah di bawah beban data masukan yang berbeda.

Perhitungan per detik

Metrik kustom

flink_taskmanager_job_task_operator_numRecordsOut

Total jumlah catatan keluaran

Jika nilai metrik ini tidak bertambah untuk waktu yang lama pada sebuah operator, mungkin terjadi kesalahan dalam logika kode pekerjaan dan data hilang. Oleh karena itu, data gagal dikirimkan. Dalam hal ini, Anda harus memeriksa logika kode pekerjaan.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numRecordsOutPerSecond

Jumlah catatan data keluaran per detik untuk aliran data

Metrik ini mengukur kecepatan keluaran keseluruhan dari aliran data. Kecepatan tersebut menunjukkan jumlah catatan data keluaran per detik untuk aliran data.

Sebagai contoh, nilai metrik ini membantu menentukan apakah kecepatan keluaran keseluruhan dari aliran data memenuhi persyaratan yang diharapkan dan bagaimana kinerja pekerjaan berubah di bawah beban data keluaran yang berbeda.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_operator_source_numRecordsIn

Total jumlah catatan data yang mengalir ke operator sumber

Metrik ini mengukur jumlah catatan data yang mengalir ke sumber.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_sink_numRecordsOut

Total jumlah catatan data keluaran dalam sink

Metrik ini mengukur jumlah catatan data yang diekspor oleh sumber.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_numRecordsInPerSecond

Jumlah catatan data masukan per detik untuk aliran data

Metrik ini mengukur kecepatan pemrosesan keseluruhan dari aliran data.

Sebagai contoh, nilai metrik ini membantu menentukan apakah kecepatan pemrosesan keseluruhan dari aliran data memenuhi persyaratan yang diharapkan dan bagaimana kinerja pekerjaan berubah di bawah beban data masukan yang berbeda.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_numRecordsOutPerSecond

Jumlah catatan data keluaran per detik untuk aliran data

Metrik ini mengukur kecepatan keluaran keseluruhan dari aliran data. Kecepatan tersebut menunjukkan jumlah catatan data keluaran per detik untuk aliran data.

Sebagai contoh, nilai metrik ini membantu menentukan apakah kecepatan keluaran keseluruhan dari aliran data memenuhi persyaratan yang diharapkan dan bagaimana kinerja pekerjaan berubah di bawah beban data keluaran yang berbeda.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_operator_source_numRecordsInPerSecond

Jumlah catatan data masukan per detik dalam sumber

Metrik ini mengukur kecepatan pembuatan catatan data dalam sumber. Kecepatan tersebut menunjukkan jumlah catatan data masukan per detik dalam sumber.

Sebagai contoh, jumlah catatan data yang dapat dibuat bervariasi berdasarkan jenis setiap sumber dalam aliran data. Nilai metrik ini membantu menentukan kecepatan pembuatan catatan data dalam sumber dan menyesuaikan aliran data untuk meningkatkan kinerja.

Metrik ini juga digunakan untuk pemantauan dan peringatan. Jika nilai metrik ini adalah 0, mungkin ada data yang hilang dari sumber. Dalam hal ini, Anda harus memeriksa apakah output data terblokir karena data dari sumber tidak dikonsumsi.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_operator_sink_numRecordsOutPerSecond

Jumlah catatan data keluaran per detik dalam sink

Metrik ini mengukur kecepatan ekspor catatan data dari sink. Kecepatan tersebut menunjukkan jumlah catatan data keluaran per detik dalam sink.

Sebagai contoh, jumlah catatan data yang dapat diekspor bervariasi berdasarkan jenis setiap sink dalam aliran data. Nilai metrik numRecordsOutOfSinkPerSecond membantu menentukan kecepatan ekspor catatan data dari sink dan menyesuaikan aliran data untuk meningkatkan kinerja.

Metrik ini juga digunakan untuk pemantauan dan peringatan. Jika nilai metrik ini adalah 0, logika kode pekerjaan mungkin tidak valid dan semua data difilter. Dalam hal ini, Anda harus memeriksa logika kode pekerjaan.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_numBuffersInLocalPerSecond

Jumlah buffer lokal yang dikonsumsi per detik

Jika nilai metrik ini besar, komunikasi antar-tugas sering terjadi pada node lokal.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_numBuffersInRemotePerSecond

Jumlah buffer yang diterima dari TaskManager jarak jauh per detik.

Metrik ini menunjukkan frekuensi komunikasi antar-TaskManager.

Hitungan/detik

Metrik kustom

flink_taskmanager_job_task_numBuffersOutPerSecond

Jumlah buffer yang dikirim ke tugas lain per detik

Metrik ini mengukur tekanan keluaran tugas dan penggunaan lebar pita jaringan.

Hitungan per detik

Metrik kustom

flink_taskmanager_job_task_numBytesInLocalPerSecond

Total jumlah byte masukan per detik

Metrik ini mengukur laju aliran data ke sumber. Ini membantu mengamati throughput pekerjaan.

Byte/detik

Metrik kustom

flink_taskmanager_job_task_operator_numBytesOutPerSecond

Total jumlah byte keluaran per detik

Metrik ini mengukur laju data yang diekspor oleh sumber. Ini membantu mengamati throughput pekerjaan.

Byte/detik

Metrik kustom

flink_taskmanager_job_task_operator_pendingRecords

Jumlah catatan data yang belum dibaca oleh sumber

Metrik ini mengukur jumlah catatan data yang belum ditarik oleh sumber dari sistem eksternal.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_sourceIdleTime

Durasi saat data tidak diproses dalam sumber

Metrik ini menentukan apakah sumber sedang idle. Jika nilai metrik ini besar, data Anda dihasilkan dengan kecepatan rendah di sistem eksternal.

Milidetik

Metrik kustom

flink_taskmanager_job_task_operator_numBytesInPerSecond

Total jumlah byte masukan per detik

Tidak tersedia

Byte/detik

Metrik kustom

flink_taskmanager_job_task_numBytesOutPerSecond

Total jumlah byte keluaran per detik

Tidak tersedia

Byte/detik

Metrik kustom

flink_taskmanager_job_task_operator_currentSendTime

Waktu yang digunakan untuk mengirim catatan terbaru

Tidak tersedia

Milidetik

Metrik kustom

flink_jobmanager_job_totalNumberOfCheckpoints

Total jumlah checkpoint

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_job_numberOfFailedCheckpoints

Jumlah checkpoint yang gagal

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_job_numberOfCompletedCheckpoints

Jumlah checkpoint yang selesai

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_job_numberOfInProgressCheckpoints

Jumlah checkpoint yang sedang berlangsung

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_job_lastCheckpointDuration

Durasi penggunaan checkpoint terakhir.

Jika checkpoint memakan waktu lama atau mengalami timeout, kemungkinan penyebabnya adalah ruang penyimpanan yang digunakan oleh data state terlalu besar, terjadi kesalahan jaringan sementara, barrier tidak selaras, atau ada tekanan balik pada data.

Milidetik

Metrik kustom

flink_jobmanager_job_lastCheckpointSize

Ukuran checkpoint terakhir

Metrik ini mengukur ukuran checkpoint terakhir yang diunggah. Metrik ini membantu menganalisis kinerja checkpoint ketika terjadi bottleneck.

Byte

Metrik kustom

flink_taskmanager_job_task_operator_state_name_stateClearLatency

Latensi maksimum operasi Clear pada data state

Metrik ini mengukur kinerja operasi Clear pada data state.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_valueStateGetLatency

Latensi maksimum operasi Get pada data ValueState

Metrik ini mengukur kinerja akses data ValueState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_valueStateUpdateLatency

Latensi maksimum operasi Update pada data ValueState

Metrik ini mengukur kinerja operasi Update pada data ValueState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_aggregatingStateGetLatency

Latensi maksimum operasi Get pada data AggregatingState

Metrik ini mengukur kinerja akses data AggregatingState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_aggregatingStateAddLatency

Latensi maksimum operasi Add pada data AggregatingState

Metrik ini mengukur kinerja operasi Add pada data AggregatingState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_aggregatingStateMergeNamespacesLatency

Latensi maksimum operasi Merge Namespace pada data AggregatingState

Metrik ini mengukur kinerja operasi Merge Namespace pada data AggregatingState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_reducingStateGetLatency

Latensi maksimum operasi Get pada data ReducingState

Metrik ini mengukur kinerja akses data ReducingState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_reducingStateAddLatency

Latensi maksimum operasi Add pada data ReducingState

Metrik ini mengukur kinerja operasi Add pada data ReducingState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_reducingStateMergeNamespacesLatency

Latensi maksimum operasi Merge Namespace pada data ReducingState

Metrik ini mengukur kinerja operasi Merge Namespace pada data ReducingState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateGetLatency

Latensi maksimum operasi Get pada data MapState

Metrik ini mengukur kinerja akses data MapState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStatePutLatency

Latensi maksimum operasi Put pada data MapState

Metrik ini mengukur kinerja operasi Put pada data MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStatePutAllLatency

Latensi maksimum operasi PutAll pada data MapState

Metrik ini mengukur kinerja operasi PutAll pada data MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateRemoveLatency

Latensi maksimum operasi Remove pada data MapState

Metrik ini mengukur kinerja operasi Remove pada data MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateContainsLatency

Latensi maksimum operasi Contains pada data MapState

Metrik ini mengukur kinerja operasi Contains pada data MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateEntriesInitLatency

Latensi maksimum operasi Init pada entri MapState

Metrik ini mengukur kinerja operasi Init pada entri MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateKeysInitLatency

Latensi maksimum operasi Init pada kunci MapState

Metrik ini mengukur kinerja operasi Init pada kunci MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateValuesInitLatency

Latensi maksimum operasi Init pada nilai MapState

Metrik ini mengukur kinerja operasi Init pada nilai MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateIteratorInitLatency

Latensi maksimum operasi Init pada Iterator MapState

Metrik ini mengukur kinerja operasi Init pada Iterator MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateIsEmptyLatency

Latensi maksimum operasi Empty pada data MapState

Metrik ini mengukur kinerja operasi Empty pada data MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateIteratorHasNextLatency

Latensi maksimum operasi HasNext pada Iterator MapState

Metrik ini mengukur kinerja operasi HasNext pada Iterator MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateIteratorNextLatency

Latensi maksimum operasi Next pada Iterator MapState

Metrik ini mengukur kinerja operasi Next pada Iterator MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_mapStateIteratorRemoveLatency

Latensi maksimum operasi Remove pada Iterator MapState

Metrik ini mengukur kinerja operasi Remove pada Iterator MapState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_listStateGetLatency

Latensi maksimum operasi Get pada data ListState

Metrik ini mengukur kinerja akses data ListState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_listStateAddLatency

Latensi maksimum operasi Add pada data ListState

Metrik ini mengukur kinerja operasi Add pada data ListState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_listStateAddAllLatency

Latensi maksimum operasi AddAll pada data ListState

Metrik ini mengukur kinerja operasi AddAll pada data ListState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_listStateUpdateLatency

Latensi maksimum operasi Update pada data ListState

Metrik ini mengukur kinerja operasi Update pada data ListState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_listStateMergeNamespacesLatency

Latensi maksimum operasi Merge Namespace pada data ListState

Metrik ini mengukur kinerja operasi Merge Namespace pada data ListState.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_sortedMapStateFirstEntryLatency

Latensi maksimum akses entri pertama dari data SortedMapState

Metrik ini mengukur kinerja akses data SortedMapState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_state_name_sortedMapStateLastEntryLatency

Latensi maksimum akses entri terakhir dari data SortedMapState

Metrik ini mengukur kinerja akses data SortedMapState oleh operator.

Nanodetik

Metrik kustom

flink_taskmanager_job_task_operator_geminiDB_total_size

Ukuran data state

Metrik ini membantu Anda melakukan operasi berikut:

• Mengidentifikasi node di mana kemungkinan terjadinya bottleneck data state.

• Memeriksa apakah TTL data state berlaku.

Byte

Metrik kustom

flink_taskmanager_job_task_operator_geminiDB_total_filesize

Ukuran file data state

Metrik ini membantu Anda melakukan operasi berikut:

• Memeriksa ukuran file data state di disk lokal. Anda dapat mengambil tindakan sebelumnya jika ukurannya besar.

• Menentukan apakah data state terlalu besar sehingga menyebabkan ruang disk lokal tidak mencukupi.

Byte

Metrik kustom

flink_taskmanager_job_task_currentInputWatermark

Waktu setiap tugas menerima watermark terbaru

Metrik ini mengukur latensi penerimaan data oleh TaskManager.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_watermarkLag

Latensi Watermark

Metrik ini mengukur latensi sub-tugas.

Milidetik

Metrik kustom

flink_jobmanager_Status_JVM_CPU_Load

Beban CPU JobManager

Jika nilai metrik ini lebih dari 100% untuk waktu yang lama, CPU sibuk dan beban CPU tinggi. Hal ini dapat memengaruhi kinerja sistem. Akibatnya, masalah seperti tersendatnya sistem dan respons lambat dapat terjadi.

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_JVM_Memory_Heap_Used

Jumlah memori heap JobManager yang digunakan

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Memory_Heap_Committed

Jumlah memori heap yang dikomit oleh JobManager

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Memory_Heap_Max

Jumlah maksimum memori heap JobManager

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Memory_NonHeap_Used

Jumlah memori non-heap JobManager yang digunakan

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Memory_NonHeap_Committed

Jumlah memori non-heap yang dikomit oleh JobManager

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Memory_NonHeap_Max

Jumlah maksimum memori non-heap JobManager

Tidak tersedia

Byte

Metrik dasar

flink_jobmanager_Status_JVM_Threads_Count

Jumlah thread JobManager

Sejumlah besar thread JobManager menempati ruang memori berlebih, mengurangi stabilitas pekerjaan.

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Count

Jumlah GC yang dilakukan dalam JobManager

GC yang sering terjadi menyebabkan konsumsi memori berlebih dan memengaruhi kinerja pekerjaan secara negatif. Metrik ini membantu mendiagnosis masalah pekerjaan dan mengidentifikasi penyebab kegagalan pekerjaan.

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Count

Jumlah young GC JobManager

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Count

Jumlah old GC JobManager

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Time

Durasi young GC JobManager

Tidak tersedia

Milidetik

Metrik kustom

flink_jobmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Time

Durasi old GC JobManager

Tidak tersedia

Milidetik

Metrik kustom

flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count

Jumlah GC yang dilakukan oleh garbage collector Concurrent Mark Sweep (CMS) JobManager

Tidak tersedia

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_JVM_GarbageCollector_ParNew_Time

Durasi setiap GC JobManager

Jika GC JobManager berlangsung lama, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan. Metrik ini membantu mendiagnosis masalah pekerjaan dan mengidentifikasi penyebab kegagalan pekerjaan.

Milidetik

Metrik dasar

flink_jobmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time

Durasi GC garbage collector CMS JobManager.

Tidak tersedia

Milidetik

Metrik dasar

flink_jobmanager_Status_JVM_ClassLoader_ClassesLoaded

Total jumlah kelas yang dimuat setelah mesin virtual Java (JVM) tempat JobManager berada dibuat

Jika total jumlah kelas yang dimuat terlalu besar setelah JVM tempat JobManager berada dibuat, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan.

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_JVM_ClassLoader_ClassesUnloaded

Total jumlah kelas yang di-unload setelah mesin virtual Java (JVM) tempat JobManager berada dibuat

Jika total jumlah kelas yang di-unload terlalu besar setelah JVM tempat JobManager berada dibuat, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_CPU_Load

Beban CPU TaskManager

Metrik ini menunjukkan jumlah total proses di mana CPU sedang menghitung data dan proses di mana data menunggu untuk dihitung oleh CPU. Dalam banyak kasus, metrik ini menunjukkan seberapa sibuk CPU.

Nilai metrik ini terkait dengan jumlah core CPU yang digunakan. Beban CPU di Flink dihitung menggunakan rumus berikut: Beban CPU = Utilisasi CPU/Jumlah core CPU. Jika nilai metrik flink_taskmanager_Status_JVM_CPU_Load lebih besar dari beban CPU di Flink, pemrosesan CPU mungkin terblokir.

Tidak tersedia

Metrik dasar

flink_jobmanager_Status_ProcessTree_CPU_Usage

Utilisasi CPU JobManager

Metrik ini menunjukkan utilisasi slice waktu CPU yang ditempati oleh Flink.

• Jika nilai metrik ini 100%, satu core CPU digunakan.

• Jika nilai metrik ini 400%, empat core CPU digunakan.

Jika nilai metrik ini lebih dari 100% untuk waktu yang lama, CPU sibuk.

Jika beban CPU tinggi tetapi utilisasi CPU rendah, sejumlah besar proses yang berada dalam keadaan tidur tak terputus mungkin berjalan karena operasi baca dan tulis yang sering.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_ProcessTree_CPU_Usage

Utilisasi CPU TaskManager

Metrik ini menunjukkan utilisasi slice waktu CPU yang ditempati oleh Flink.

• Jika nilai metrik ini 100%, satu core CPU digunakan.

• Jika nilai metrik ini 400%, empat core CPU digunakan.

Jika nilai metrik ini lebih dari 100% untuk waktu yang lama, CPU sibuk.

Jika beban CPU tinggi tetapi utilisasi CPU rendah, sejumlah besar proses yang berada dalam keadaan tidur tak terputus mungkin berjalan karena operasi baca dan tulis yang sering.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_Memory_Heap_Used

Jumlah memori heap TaskManager yang digunakan

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Memory_Heap_Committed

Jumlah memori heap yang dikomit oleh TaskManager

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Memory_Heap_Max

Jumlah maksimum memori heap TaskManager

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Memory_NonHeap_Used

Jumlah memori non-heap TaskManager yang digunakan

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Memory_NonHeap_Committed

Jumlah memori non-heap yang dikomit oleh TaskManager

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Memory_NonHeap_Max

Jumlah maksimum memori non-heap TaskManager

Tidak tersedia

Byte

Metrik dasar

flink_taskmanager_Status_ProcessTree_Memory_RSS

Jumlah memori yang dikonsumsi oleh seluruh proses di Linux

Metrik ini melacak perubahan konsumsi memori proses.

Byte

Metrik dasar

flink_taskmanager_Status_JVM_Threads_Count

Jumlah thread TaskManager

Sejumlah besar thread TaskManager menempati ruang memori berlebih, mengurangi stabilitas pekerjaan.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Count

Jumlah GC yang dilakukan dalam TaskManager

GC yang sering terjadi menyebabkan konsumsi memori berlebih dan memengaruhi kinerja pekerjaan secara negatif. Metrik ini membantu mendiagnosis masalah pekerjaan dan mengidentifikasi penyebab kegagalan pekerjaan.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Count

Jumlah young GC TaskManager

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_taskmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Count

Jumlah old GC TaskManager

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_taskmanager_Status_JVM_GarbageCollector_G1_Young_Generation_Time

Durasi young GC TaskManager

Tidak tersedia

Milidetik

Metrik kustom

flink_taskmanager_Status_JVM_GarbageCollector_G1_Old_Generation_Time

Durasi old GC TaskManager

Tidak tersedia

Milidetik

Metrik kustom

flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Count

Jumlah GC yang dilakukan oleh garbage collector CMS TaskManager

Tidak tersedia

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_GarbageCollector_ParNew_Time

Durasi setiap GC TaskManager

Jika GC TaskManager berlangsung lama, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan. Metrik ini membantu mendiagnosis masalah pekerjaan dan mengidentifikasi penyebab kegagalan pekerjaan.

Milidetik

Metrik dasar

flink_taskmanager_Status_JVM_GarbageCollector_ConcurrentMarkSweep_Time

Durasi GC garbage collector CMS TaskManager

Tidak tersedia

Milidetik

Metrik dasar

flink_taskmanager_Status_JVM_ClassLoader_ClassesLoaded

Total jumlah kelas yang dimuat setelah JVM tempat TaskManager berada dibuat

Jika total jumlah kelas yang dimuat terlalu besar setelah JVM tempat TaskManager berada dibuat, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan.

Tidak tersedia

Metrik dasar

flink_taskmanager_Status_JVM_ClassLoader_ClassesUnloaded

Total jumlah kelas yang di-unload setelah JVM tempat TaskManager berada dibuat

Jika total jumlah kelas yang di-unload terlalu besar setelah JVM tempat TaskManager berada dibuat, ruang memori berlebih ditempati, memengaruhi kinerja pekerjaan.

Tidak tersedia

Metrik dasar

flink_jobmanager_job_uptime

Periode selama pekerjaan berjalan.

Tidak tersedia

Milidetik

Metrik kustom

flink_jobmanager_numRunningJobs

Jumlah pekerjaan yang sedang berjalan

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_taskSlotsAvailable

Jumlah slot tugas yang tersedia

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_taskSlotsTotal

Total jumlah slot tugas

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_numRegisteredTaskManagers

Jumlah TaskManager yang terdaftar

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_numBytesInRemotePerSecond

Jumlah byte yang dibaca dari sumber jarak jauh per detik

Tidak tersedia

Byte/detik

Metrik kustom

flink_taskmanager_job_task_operator_numLateRecordsDropped

Jumlah paket yang di-drop karena latensi window

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_lateRecordsDroppedRate

Laju latensi window

Tidak tersedia

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_isSnapshotting

Apakah pekerjaan berada dalam fase data penuh

Metrik ini menunjukkan fase pemrosesan pekerjaan.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_isBinlogReading

Apakah pekerjaan berada dalam fase inkremental

Metrik ini menunjukkan fase pemrosesan pekerjaan.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_numTablesRemaining

Jumlah tabel yang belum diproses dalam fase data penuh

Metrik ini mengukur jumlah tabel yang belum diproses.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_numTablesSnapshotted

Jumlah tabel yang menunggu untuk diproses dalam fase data penuh

Metrik ini mengukur jumlah tabel yang belum diproses.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_numSnapshotSplitsProcessed

Jumlah tabel yang telah diproses dalam fase data penuh

Metrik ini mengukur jumlah tabel yang telah diproses.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_cdcns_schema_table_numSnapshotSplitsProcessed

Jumlah shard yang telah diproses dalam fase data penuh

Metrik ini mengukur jumlah shard yang telah diproses.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_numSnapshotSplitsRemaining

Jumlah shard yang menunggu untuk diproses dalam fase data penuh

Metrik ini mengukur jumlah shard yang belum diproses.

Tidak tersedia

Metrik kustom

flink_jobmanager_job_operator_coordinator_enumerator_cdcns_schema_table_numSnapshotSplitsRemaining

Jumlah shard yang menunggu untuk diproses dalam fase data penuh

Metrik ini mengukur jumlah shard yang belum diproses.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_currentReadTimestampMs

Timestamp catatan data terbaru yang dibaca

Metrik ini mengukur waktu data log biner terbaru.

Milidetik

Metrik kustom

flink_taskmanager_job_task_operator_numSnapshotRecords

Jumlah catatan data yang diproses dalam fase data penuh

Metrik ini mengukur jumlah catatan data yang diproses dalam fase data penuh.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numRecordsIn

Jumlah catatan data yang dibaca dari setiap tabel

Metrik ini mengukur jumlah total catatan data yang diproses di setiap tabel.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numSnapshotRecords

Jumlah catatan data yang diproses di setiap tabel dalam fase data penuh

Metrik ini mengukur jumlah catatan data yang diproses di setiap tabel dalam fase data penuh.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numInsertDMLRecords

Jumlah pernyataan DML INSERT yang dieksekusi untuk setiap tabel dalam fase inkremental

Metrik ini mengukur jumlah pernyataan INSERT yang dieksekusi untuk setiap tabel.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numUpdateDMLRecords

Jumlah pernyataan DML UPDATE yang dieksekusi untuk setiap tabel dalam fase inkremental

Metrik ini mengukur jumlah pernyataan UPDATE yang dieksekusi untuk setiap tabel.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numDeleteDMLRecords

Jumlah pernyataan DML DELETE yang dieksekusi untuk setiap tabel dalam fase inkremental

Metrik ini mengukur jumlah pernyataan DELETE yang dieksekusi untuk setiap tabel.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_cdcns_schema_table_numDDLRecords

Jumlah pernyataan DDL yang dieksekusi untuk setiap tabel dalam fase inkremental

Metrik ini mengukur jumlah pernyataan DDL yang dieksekusi untuk setiap tabel.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numInsertDMLRecords

Jumlah pernyataan DML INSERT yang dieksekusi dalam fase inkremental

Metrik ini mengukur jumlah pernyataan INSERT yang dieksekusi.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numUpdateDMLRecords

Jumlah pernyataan DML UPDATE yang dieksekusi dalam fase inkremental

Metrik ini mengukur jumlah pernyataan UPDATE yang dieksekusi.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numDeleteDMLRecords

Jumlah pernyataan DML DELETE yang dieksekusi dalam fase inkremental

Metrik ini mengukur jumlah pernyataan DELETE yang dieksekusi.

Tidak tersedia

Metrik kustom

flink_taskmanager_job_task_operator_numDDLRecords

Jumlah pernyataan DDL yang dieksekusi dalam fase inkremental

Metrik ini mengukur jumlah pernyataan DDL yang dieksekusi.

Tidak tersedia

Metrik kustom

Label

Deskripsi

vvpNamespace

Nama namespace.

deploymentName

Nama deployment.

deploymentId

ID deployment.

jobId

ID pekerjaan.