Flink环境搭建

发表于 | 分类于
字数统计: 128 | 阅读时长 ≈ 1

Flink入门——Flink环境搭建

1. 环境准备

Flink官方网站：https://flink.apache.org

目前的最新版本是：flink-1.6.1

JDK版本

JDK版本需要1.8以上

2. 基础命令

1
2
cd /usr/local/flink-1.6.1
./bin/start-cluster.sh
1
./bin/stop-cluster.sh

查看运行 log

1
tail -f /usr/local/bigData/flink-1.6.1/log/flink-*-standalonesession-*.log

查看执行的log

1
tail -f /usr/local/bigData/flink-1.6.1/log/flink-*-taskexecutor-*.log

提交job:

1
./bin/flink run -c class_name jar_name

class_name： job的主类名
jar_name：jar包名称