Flink
Apache Flink 是一个框架和分布式处理引擎,用于在无边界和有边界数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行,并能以内存速度和任意规模进行计算。
1. 本地安装文档
# 1. 进入opt目录 并且 下载tgz 包
cd /opt &&
wget https://dlcdn.apache.org/flink/flink-1.17.1/flink-1.17.1-bin-scala_2.12.tgz --no-check-certificate
# 2. 解压
tar -zxvf flink-1.17.1-bin-scala_2.12.tgz
# 3. 启动 (需要先安装JDK8 +)
cd flink-1.17.1/ && ./bin/start-cluster.sh
# 4. 提交作业(示例)
./bin/flink run examples/streaming/WordCount.jar
# 4.1 查看运行日志
tail log/flink-*-taskexecutor-*.out
# 4.2 通过WEB UI 查看,(http://IP:8081)
# 5. 停止服务
./bin/stop-cluster.sh
参考
https://blog.csdn.net/chenwewi520feng/article/details/131530503