Utilisation de l'interface utilisateur Flink pour surveiller les tâches Flink

Pour surveiller l'état et les performances d'une application Flink en cours d'exécution, utilisez le tableau de bord web de Flink. Ce tableau de bord fournit des informations sur le statut de la tâche, le nombre de tâches TaskManagers, les métriques et les journaux associés à la tâche. Il vous permet également de consulter et de modifier la configuration de la tâche Flink, et d'interagir avec le cluster Flink pour soumettre ou annuler des tâches.

Pour accéder au tableau de bord Web de Flink pour une application Flink en cours d'exécution sur Kubernetes :

1. Utilisez la kubectl port-forward commande pour transférer un port local vers le port sur lequel le tableau de bord Web Flink s'exécute dans les modules de TaskManager l'application Flink. Par défaut, ce port est 8081. Remplacez deployment-name par le nom du déploiement de l'application Flink indiqué ci-dessus.

   kubectl get deployments -n namespace

   Exemple de sortie :

   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. Si vous souhaitez utiliser un port différent au niveau local, utilisez le paramètre local-port:8081.

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

3. Dans un navigateur web, naviguez vers http://localhost:8081 (ou http://localhost:local-port si vous avez utilisé un port local personnalisé) pour accéder au tableau de bord web de Flink. Ce tableau de bord affiche des informations sur l'application Flink en cours d'exécution, telles que le statut de la tâche, le nombre de tâches TaskManagers, les métriques et les journaux associés à la tâche.