Apache Flink Tutorial
Selected Reading
- Apache Flink - Discussion
- Apache Flink - Useful Resources
- Apache Flink - Quick Guide
- Apache Flink - Conclusion
- Apache Flink - Flink vs Spark vs Hadoop
- Apache Flink - Use Cases
- Apache Flink - Machine Learning
- Apache Flink - Libraries
- Apache Flink - Running a Flink Program
- Creating a Flink Application
- Apache Flink - Table API and SQL
- Apache Flink - API Concepts
- Apache Flink - Setup/Installation
- Apache Flink - System Requirements
- Apache Flink - Architecture
- Apache Flink - Introduction
- Batch vs Real-time Processing
- Apache Flink - Big Data Platform
- Apache Flink - Home
Selected Reading
- Who is Who
- Computer Glossary
- HR Interview Questions
- Effective Resume Writing
- Questions and Answers
- UPSC IAS Exams Notes
Apache Flink - Running a Flink Program
Apache Fpnk - Running a Fpnk Program
In this chapter, we will learn how to run a Fpnk program.
Let us run the Fpnk wordcount example on a Fpnk cluster.
Go to Fpnk s home directory and run the below command in the terminal.
bin/fpnk run examples/batch/WordCount.jar -input README.txt -output /home/ubuntu/fpnk-1.7.1/output.txt
![Fpnk Home Directory](/apache_fpnk/images/fpnk_home_directory.jpg)
Go to Fpnk dashboard, you will be able to see a completed job with its details.
![Fpnk dashboard](/apache_fpnk/images/fpnk_dashboard.jpg)
If you cpck on Completed Jobs, you will get detailed overview of the jobs.
![Cpck Completed Jobs](/apache_fpnk/images/cpck_completed_jobs.jpg)
To check the output of wordcount program, run the below command in the terminal.
cat output.txt
![Output Wordcount Program](/apache_fpnk/images/output_wordcount_program.jpg)