Uso dell'interfaccia utente Flink per monitorare i processi Flink

Per monitorare lo stato e le prestazioni di un'applicazione Flink in esecuzione, utilizza Flink Web Dashboard. Questa dashboard fornisce informazioni sullo stato del lavoro, sul numero di, sulle metriche e sui registri del lavoro. TaskManagers Consente inoltre di visualizzare e modificare la configurazione del processo Flink e di interagire con il cluster Flink per inviare o annullare i processi.

Procedura per accedere a Flink Web Dashboard per un'applicazione Flink in esecuzione su Kubernetes:

1. Utilizzate il kubectl port-forward comando per inoltrare una porta locale alla porta su cui è in esecuzione Flink Web Dashboard nei pod dell'applicazione Flink. TaskManager Per impostazione predefinita, la porta è 8081. Sostituisci deployment-name con il nome dell'implementazione dell'applicazione Flink di cui sopra.

   kubectl get deployments -n namespace

   Output di esempio:

   kubectl get deployments -n flink-namespace
   NAME                        READY   UP-TO-DATE   AVAILABLE  AGE
   basic-example               1/1       1            1           11m
   flink-kubernetes-operator   1/1       1            1           21h

   kubectl port-forward deployments/deployment-name 8081 -n namespace

2. Se desideri utilizzare una porta diversa a livello locale, utilizza il parametro local-port:8081.

   kubectl port-forward -n flink deployments/basic-example 8080:8081

3. In un browser web, apri http://localhost:8081 (o http://localhost:local-port, se hai utilizzato una porta locale personalizzata) per accedere a Flink Web Dashboard. Questa dashboard mostra informazioni sull'applicazione Flink in esecuzione, come lo stato del lavoro, il numero di TaskManagers, le metriche e i registri relativi al lavoro.