Apache Flink - Ejecución de un programa Flink

En este capítulo, aprenderemos cómo ejecutar un programa Flink.

Ejecutemos el ejemplo de conteo de palabras de Flink en un clúster de Flink.

Vaya al directorio de inicio de Flink y ejecute el siguiente comando en la terminal.

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

Vaya al panel de Flink, podrá ver un trabajo completado con sus detalles.

Si hace clic en Trabajos completados, obtendrá una descripción detallada de los trabajos.

Para verificar la salida del programa de conteo de palabras, ejecute el siguiente comando en la terminal.

cat output.txt