flink+centOS

■ flink 日本語マニュアル
http://mogile.web.fc2.com/flink/flink-docs-release-1.3/dev/connectors/kafka.html

■ flink ダウンロードページ
https://flink.apache.org/downloads.html

■ flink install(centOS)
□ yum をupdateしておく
# yum update

□ wget をインストールする
# yum install wget

□ java をインストールする
Javaインストール
# yum install java-1.8.0-openjdk-devel
javahome設定
# vi /etc/profile
export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-2.el7_6.x86_64
export PATH=$PATH:$JAVA_HOME/bin
export CLASSPATH=.:$JAVA_HOME/jre/lib:$JAVA_HOME/lib:$JAVA_HOME/lib/tools.jar

□ flink最新版をダウンロード
# wget https://www-eu.apache.org/dist/flink/flink-1.8.0/flink-1.8.0-bin-scala_2.12.tgz
# tar xzf flink-1.8.0-bin-scala_2.12.tgz
# cd flink-1.8.0

□ selinux無効化★必ず無効化すること
https://qiita.com/hanaita0102/items/5d3675e4dc1530b255ba
□ iptables★無視してOK

□ firewalld無効化★必ず無効化すること
https://www.server-memo.net/centos-settings/centos7/firewalld-stop.html

□ flinkスタート
# ./bin/start-cluster.sh
http://192.168.56.111:8081/

□ flink自動起動設定
# vi /etc/rc.local
以下を追記
sh /test01/flink-1.8.0/bin/start-cluster.sh
# chmod u+x /etc/rc.d/rc.local

□ quick startを続ける
# yum install nc
# cd /test01/flink-1.8.0
# nc -l 9000
# ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
※ 上手くいかないときは、思い切ってreboot