网上很多写的很乱，看不明白，故此记录。

前提：
flink版本：1.10.0
zk集群
hadoop集群

一、flink-session方式

• 在yarn中启动一个长久运行的flink集群，提交任务时都提交到这个flink-session集群中运行，适合小任务。
• 做HA：保证YarnSessionClusterEntrypoint的高可用，需要在yarn里配置yarn.resourcemanager.am.max-
  attempts，在flink-conf.yaml中添加high-availiability的配置
• 提交任务命令：
    先启动yarn-session，
    然后直接flink run ..

二、per-job方式

• 每次提交任务都单独启动一个flink集群，适合长久运行的大任务。
• HA：per-job的高可用是复用的 standalone HA 的，所以需要配置flink的standalone HA和yarn.application-attempts: 3
• 提交任务命令：
  flink run -m yarn-cluster -yqu root.myjob1 ..

三、per-job方式在yarn上一直是accept状态，flink报错：deployment took more than 60 secoeds

flink还不完善，也不想诟病了
分析：我这里是，由于yarn调度器实际上是一个队列，在yarn-cluster选项中有-yqu这个参数，表示指定一个队列，如果你已经提交了一个per-job任务，再次提交必须指定一个新的队列名称，否则他会一直等待之前的任务结束后，新的job才能running，所以一直是accept。

解决：flink run -m yarn-cluster -yqu root.myjob1 ..

另：flink1.10已经不必需要-yn了，它会自动去检测。