Apache Flink - executando um programa Flink

Neste capítulo, aprenderemos como executar um programa Flink.

Vamos executar o exemplo de contagem de palavras do Flink em um cluster do Flink.

Vá para o diretório inicial do Flink e execute o comando abaixo no terminal.

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

Acesse o painel do Flink, você poderá ver um trabalho concluído com seus detalhes.

Se você clicar em Trabalhos concluídos, obterá uma visão geral detalhada dos trabalhos.

Para verificar a saída do programa de contagem de palavras, execute o comando abaixo no terminal.

cat output.txt