https://flink.apache.org/zh/downloads.html


# jdk


# flink

cd   /data/site/htmltoo.opt

wget  https://dlcdn.apache.org/flink/flink-2.0.0/flink-2.0.0-bin-scala_2.12.tgz

tar xzf  flink-*.tgz

cd  flink-2.0.0


# 环境变量

vim /etc/profile

export FLNK_HOME=/data/site/htmltoo.opt/flink-2.0.0

export PATH=$FLINK_HOME/bin:$PATH

source /etc/profile


# 进入conf配置文件目录下,主要配置文件维flink-conf.yaml

jobmanager.rpc.port: 6123    –  jobManager 的端口,默认为6123 


# 启动

./bin/start-cluster.sh

./bin/stop-cluster.sh

jps


# 日志

tail -f  ../log/flink-root-standalonesession-*.log


# web前端

http://ip:8081


# 通过命令行提交任务到 Flink Standalone cluster

bash bin/flink-cdc.sh mysql-to-starrocks.yaml


签名:这个人很懒,什么也没有留下!
最新回复 (0)
返回