hi??all??

??????????????https://blog.csdn.net/cndotaci/article/details/106870413??????????????flink????yarn??????????????????????????????????????2??????????????????????6????????????????????yarn??????

????????????

1. ????????????????????????????????????

2. ????HA????????????????????????????????????????state??

flink??????1.10.0

flink-conf.yaml??????
$ grep -v ^# flink-conf.yaml |grep -v ^$ jobmanager.rpc.address: localhost 
jobmanager.rpc.port: 6123 jobmanager.heap.size: 1024m 
taskmanager.memory.process.size: 1568m taskmanager.numberOfTaskSlots: 1 
parallelism.default: 1 high-availability: zookeeper 
high-availability.storageDir: hdfs:///flink/ha/ 
high-availability.zookeeper.quorum: 
uhadoop-op3raf-master1,uhadoop-op3raf-master2,uhadoop-op3raf-core1 
state.checkpoints.dir: hdfs:///flink/checkpoint state.savepoints.dir: 
hdfs:///flink/flink-savepoints state.checkpoints.num-retained:60 
state.backend.incremental: true jobmanager.execution.failover-strategy: region 
jobmanager.archive.fs.dir: hdfs:///flink/flink-jobs/ historyserver.web.port: 
8082 historyserver.archive.fs.dir: hdfs:///flink/flink-jobs/ 
historyserver.archive.fs.refresh-interval: 10000 # HA???????? 
yarn.application-attempts: 2 
ssh??jm??????????kill????????????????
[root@uhadoop-op3raf-task48 ~]# jps 34785 YarnTaskExecutorRunner 16853 
YarnTaskExecutorRunner 17527 PrestoServer 33289 YarnTaskExecutorRunner 18026 
YarnJobClusterEntrypoint 20283 Jps 39599 NodeManager 
[root@uhadoop-op3raf-task48 ~]# kill -9 18026 [root@uhadoop-op3raf-task48 ~]# 
jps 34785 YarnTaskExecutorRunner 16853 -- process information unavailable 17527 
PrestoServer 21383 Jps 33289 YarnTaskExecutorRunner 20412 
YarnJobClusterEntrypoint 39599 NodeManager [root@uhadoop-op3raf-task48 ~]# kill 
-9 20412 [root@uhadoop-op3raf-task48 ~]# jps 34785 YarnTaskExecutorRunner 21926 
YarnJobClusterEntrypoint 23207 Jps 17527 PrestoServer 33289 
YarnTaskExecutorRunner 39599 NodeManager [root@uhadoop-op3raf-task48 ~]# kill 
-9 21926 [root@uhadoop-op3raf-task48 ~]# jps 34785 YarnTaskExecutorRunner 23318 
YarnJobClusterEntrypoint 26279 Jps 17527 PrestoServer 33289 
YarnTaskExecutorRunner 39599 NodeManager [root@uhadoop-op3raf-task48 ~]# kill 
-9 23318

Reply via email to