Apache Flink - Exécution d'un programme Flink

Dans ce chapitre, nous allons apprendre à exécuter un programme Flink.

Exécutons l'exemple Flink wordcount sur un cluster Flink.

Accédez au répertoire personnel de Flink et exécutez la commande ci-dessous dans le terminal.

bin/flink run examples/batch/WordCount.jar -input README.txt -output /home/ubuntu/flink-1.7.1/output.txt

Accédez au tableau de bord Flink, vous pourrez voir un travail terminé avec ses détails.

Si vous cliquez sur Travaux terminés, vous obtiendrez un aperçu détaillé des travaux.

Pour vérifier la sortie du programme wordcount, exécutez la commande ci-dessous dans le terminal.

cat output.txt