flink-hadoop

Apache flink with hadoop 1

Apache flink with hadoop 1

What is Apache flink ?

Flink’s core is a streaming dataflow engine that provides data distribution, communication, and fault tolerance for distributed computations over data streams.

Click Here official site

For video reference : Click here 

Apache flink with hadoop Example

Step 1 : Start your hadoop 1.

flink with hadoop
flink with hadoop

Step 2 : Start your Apache flink.

Apache flink
Apache flink

Step 3 : List all the daemons.

flink with hadoop
flink with hadoop

Step 4 : Copy the wordcount.txt form local to your hdfs.

flink with hadoop
flink with hadoop

Step 5 : Run the Worcount.jar from Apache flink to the input file in hdfs.

flink with hadoop
flink with hadoop

Step : 6 Now check the output in hdfs web UI.

flink with hadoop
flink with hadoop
flink with hadoop
flink with hadoop

Step 7 : Also check the web UI of Apache flink.

Web UI of Apache flink runs in http://localhost:8081