????????????????????????hadoop????????
<property>
<name>fs.defaultFS</name>
<value>hdfs://hacluster/</value>
</property>
<property>
<name>dfs.client.failover.proxy.provider.hacluster</name>
<value>org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider</value>
</property>
hadoop??????????namenode??????
1.????????flink????????????????flink??????????????hadoop????????hadoop????????
2.??????????????????????hdfs
ha????????????????flink??????????????????????????????????hadoop??????????hadoop??????
------------------ ???????? ------------------
??????: "Lin Li"<[email protected]>;
????????: 2019??4??2??(??????) ????9:47
??????: "user-zh"<[email protected]>;
????: Re: flink on yarn ha ??????????
hdfs ha mode ?????? logical name (
https://hadoop.apache.org/docs/stable/hadoop-project-dist/hadoop-hdfs/HDFSHighAvailabilityWithNFS.html
)
flink ???????????? hdfs logical name (???????????? flink task ????????
hdfs-client ??????????
hdfs ha ?????? hdfs logical name ???????????? namedone ????????)
?????? <[email protected]> ??2019??4??2?????? ????9:07??????
> flink on yarn ha??????
> state.checkpoints.dir:
> hdfs://namenode-host:port/flink-checkpoints??????????????????????namenode??????????
>
> ????????????namenode??hostname,????????namenode????????,????standby????,flink????checkpoint????????????????????????????????????????active????
> ????hadoop namenode????????ha????????????kill
> ????namenode????????????????????????flink??????????????????????????
>
>
> ??????????????????????????flink????????
