Installation and testing of Flink

Want to make APP Same thing as WeChat , Can run small programs smoothly ？ | Experience will send you to Xinjiang 、 Huawei 、 Cherry keyboard ！>>>

One . Flink The download

Installation package download address , Select the corresponding Hadoop Of Flink Version download

 

 

 

 Flink  There are three deployment modes , Namely  Local、Standalone Cluster  and  Yarn Cluster.

Two . Local Pattern

about  Local  Mode ,JobManager  and  TaskManager  Will share one  JVM  To complete  Workload. If you want to validate a simple application ,Local  Patterns are the most convenient . Most of the practical applications use  Standalone  perhaps  Yarn Cluster, and local Mode just unzip the installation package and start it up （./bin/start-local.sh） that will do , There's no demonstration here .

3、 ... and . Standalone  Pattern

1.   Cluster deployment planning

The name of the node	master	worker	zookeeper
hadoop01	master		zookeeper
hadoop02	master	worker	zookeeper
hadoop03		woker	zookeeper

 

 

 

 

 

 

 

2.  decompression

[hadoop@hadoop01 apps]$ tar -zxvf flink-1.7.2-bin-scala_2.11.tgz -C ./

  [hadoop@hadoop01 apps]$ ls
  azkaban flink-1.7.2 flink-1.7.2-bin-scala_2.11.tgz flume-1.8.0 hadoop-2.7.4 jq kafka_2.11-0.11 zkdata zookeeper-3.4.10 zookeeper.out

3.  Modify the configuration file

[hadoop@hadoop01 apps]$ cd flink-1.7.2/
[hadoop@hadoop01 flink-1.7.2]$ ls
bin conf examples lib LICENSE licenses log NOTICE opt README.txt
[hadoop@hadoop01 flink-1.7.2]$ cd conf/
[hadoop@hadoop01 conf]$ ls
flink-conf.yaml log4j-console.properties log4j-yarn-session.properties logback.log4j-cli.properties log4j.properties logback-console.

modify fli.........