Apache Flink - Chạy chương trình Flink

Trong chương này, chúng ta sẽ học cách chạy một chương trình Flink.

Hãy để chúng tôi chạy ví dụ đếm từ Flink trên một cụm Flink.

Vào thư mục chính của Flink và chạy lệnh dưới đây trong terminal.

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

Vào bảng điều khiển Flink, bạn sẽ có thể xem một công việc đã hoàn thành với các chi tiết của nó.

Nếu bạn nhấp vào Công việc đã hoàn thành, bạn sẽ có tổng quan chi tiết về các công việc.

Để kiểm tra kết quả đầu ra của chương trình wordcount, hãy chạy lệnh dưới đây trong terminal.

cat output.txt