Apache Flink - เรียกใช้โปรแกรม Flink

ในบทนี้เราจะเรียนรู้วิธีเรียกใช้โปรแกรม Flink

ให้เราเรียกใช้ตัวอย่าง Flink wordcount บนคลัสเตอร์ Flink

ไปที่โฮมไดเร็กทอรีของ Flink และเรียกใช้คำสั่งด้านล่างในเทอร์มินัล

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

ไปที่แดชบอร์ด Flink คุณจะสามารถดูงานที่เสร็จสมบูรณ์พร้อมรายละเอียด

หากคุณคลิกที่งานที่เสร็จสมบูรณ์คุณจะเห็นภาพรวมโดยละเอียดของงาน

ในการตรวจสอบผลลัพธ์ของโปรแกรม wordcount ให้รันคำสั่งด้านล่างในเทอร์มินัล

cat output.txt