Flink 弹性伸缩 – Reactive 模式 ( 上 )
一、Reactive 模式作业提交示例脚本
wget https://dlcdn.apache.org/flink/flink-1.13.5/flink-1.13.5-bin-scala_2.11.tgz
tar -xzvf flink-1.13.5-bin-scala_2.11.tgz
cd flink-1.13.5/
mkdir usrlib
cp ./examples/streaming/TopSpeedWindowing.jar usrlib/
./bin/standalone-job.sh start -Dscheduler-mode=reactive -Dexecution.checkpointing.interval="10s" -j org.apache.flink.streaming.examples.windowing.TopSpeedWindowing
./bin/taskmanager.
共有 0 条评论