丝路通:Flink单机版安装配置

下载安装flink

下载flink

https://flink.apache.org/downloads.html#all-stable-releases

版本：flink-1.10.1

解压flink安装包

将flink-1.10.1-bin-scala_2.11.tgz通过新建文件传输上传到linux。

tar -zxf /opt/flink-1.10.1-bin-scala_2.11.tgz -C /usr/local

vim /etc/profile

export FLINK_HOME=/usr/local/flink-1.10.1
export PATH=$FLINK_HOME/bin:$PATH

source /etc/profile

mkdir -p /var/log/flink/tmp

启动与停止

启动flink集群

/usr/local/flink-1.10.1/bin/start-cluster.sh

Starting cluster.
Starting standalonesession daemon on host maxin.
Starting taskexecutor daemon on host maxin.

查看进程jps [root@master flink-1.10.1]# jps

10753 StandaloneSessionClusterEntrypoint
4405 QuorumPeerMain
10822 TaskManagerRunner
10907 Jps
10510 StandaloneSessionClusterEntrypoint

浏览器查看

浏览器登录 http://10.0.0.30:8081

关闭flink集群

[root@master flink-1.10.1]# /usr/local/flink-1.10.1/bin/stop-cluster.sh

Stopping taskexecutor daemon (pid: 7356) on host slave1.centos.com.
Stopping taskexecutor daemon (pid: 5130) on host slave2.centos.com.
Stopping taskexecutor daemon (pid: 2589) on host slave3.centos.com.
Stopping standalonesession daemon (pid: 10753) on host master.centos.com.