Apache Flink - Esecuzione di un programma Flink

In questo capitolo impareremo come eseguire un programma Flink.

Eseguiamo l'esempio di conteggio parole Flink su un cluster Flink.

Vai alla home directory di Flink ed esegui il comando seguente nel terminale.

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

Vai alla dashboard di Flink, sarai in grado di vedere un lavoro completato con i suoi dettagli.

Se fai clic su Lavori completati, otterrai una panoramica dettagliata dei lavori.

Per controllare l'output del programma conteggio parole, eseguire il comando seguente nel terminale.

cat output.txt