目录

Flink

Flink

1 OverView

2 Flink install

#本文采用Flink1.9.1 scala_2.11
https://flink.apache.org/downloads.html#apache-flink-191
wget https://www.apache.org/dyn/closer.lua/flink/flink-1.9.1/flink-1.9.1-bin-scala_2.11.tgz

#and download hadoop2.6.5  jar lib
Pre-bundled Hadoop 2.6.5
wget https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.6.5-7.0/flink-shaded-hadoop-2-uber-2.6.5-7.0.jar
#解压到flink/lib/

2.2 Quickstart On Yarn

https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/yarn_setup.html
./bin/yarn-session.sh -jm 1024m -tm 4096m
运行后会打印url地址

-w1437

./bin/flink run -m yarn-cluster -p 4 -yjm 1024m -ytm 4096m ./examples/batch/WordCount.jar