Flink4:Local模式部署

1.0 环境需求

• Java：java8或者java11

• Flink：flink-1.14.3

下载

Apache Flink® 1.14.3 是我们最新的稳定版本。 发布说明 如果你计划从以前的版本升级 Flink，请查看 Flink 1.14 的发布说明 。 发布说明 如果你计划从以前的版本升级 Flink，请查看 Flink 1.13 的发布说明 。 发布说明 如果你计划从以前的版本升级 Flink，请查看 Flink 1.12 的发布说明 。 发布说明 如果你计划从以前的版本升级 Flink，请查看 Flink 1.11 的发布说明 。 Apache Flink® Stateful Functions 3.2.0 是 Stateful Functions 组件的最新稳定版本.

https://flink.apache.org/zh/downloads.html#apache-flink-1143

1. 解压

root@redis01:/usr/local# tar -zxvf flink-1.14.3-bin-scala_2.12.tgz

2. 重命名

# 重命名
root@redis01:/usr/local# mv flink-1.14.3 flink-local

3. 启动

root@redis01:/usr/local/flink-local# ./bin/start-cluster.sh

4. 启动失败

• 使用jps查看，flink进程始终没有启动

• 进入日志log文件夹查看

root@redis01:/usr/local/flink-local/log# cat flink-root-taskexecutor-3-redis01.log

Apache flink job crashes with exception java.lang.IllegalAccessError: class org.apache.flink.util.NetUtils on start_cluster

Just downloaded Flink 1.13.1 and wanted to run a small local test project. My java version is: [![enter image description here][1]][1] pneelaka@MacBook-Pro Apache % pneelaka@MacBook-Pro Apache % $FLINK_HOME/bin/start-cluster.sh Starting cluster. Starting standalonesession daemon on host MacBook-Pro. Starting taskexecutor daemon on host MacBook-Pro. pneelaka@MacBook-Pro Apache % The UI at localhost:8081 does not launch.

https://stackoverflow.com/questions/68149415/apache-flink-job-crashes-with-exception-java-lang-illegalaccesserror-class-org

root@redis01:/usr/local/flink-local/log# java -version
openjdk version "17.0.1" 2021-10-19
OpenJDK Runtime Environment (build 17.0.1+12-Ubuntu-120.04)
OpenJDK 64-Bit Server VM (build 17.0.1+12-Ubuntu-120.04, mixed mode, sharing)

5. 修改Java版本

Java2:Ubuntu20.04安装java

6. 启动

root@redis01:/usr/local/flink-local# ./bin/start-cluster.sh

7. 访问Web UI

8. 停止Flink

root@redis01:/usr/local/flink-local# ./bin/stop-cluster.sh