柚子快報(bào)激活碼778899分享：大數(shù)據(jù) Flink 下載安裝

http://yzkb.51969.com/

# 下載 Flink 1.61

wget https://archive.apache.org/dist/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz

# 解壓 Flink

tar -xzf flink-1.16.1-bin-scala_2.12.tgz

# 進(jìn)入 Flink 目錄

cd flink-1.16.1

修改配置文件開(kāi)啟checkpoint和savepoint

vi/flink-conf.yaml

# 修改如下配置

execution.checkpointing.interval: 3min

state.backend: filesystem

# checkpoint存儲(chǔ)位置

state.checkpoints.dir: file:///home/flink/flink-1.16.1/flink-checkpoints

# savepoint存儲(chǔ)位置

state.savepoints.dir: file:///home/flink/flink-1.16.1/flink-savepoints

#web開(kāi)啟遠(yuǎn)程訪問(wèn)

rest.bind-address: 0.0.0.0：

classloader.resolve-order: parent-first

#固定間隔策略,表示每10s重試一次，最多重試3次

restart-strategy: fixed-delay

restart-strategy.fixed-delay.attempts: 3

restart-strategy.fixed-delay.delay: 10 s

啟動(dòng) Flink 集群

# 啟動(dòng) Flink 集群

./bin/start-cluster.sh

# 返回如下信息，表示成功啟動(dòng) flink 集群

Starting cluster.

Starting standalonesession daemon on host.

Starting taskexecutor daemon on host.

Flink WebUI http://localhost:8081

柚子快報(bào)激活碼778899分享：大數(shù)據(jù) Flink 下載安裝

http://yzkb.51969.com/

好文推薦