ha namenode config的hdfs上的flink检查点

enxuqcxy  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(373)

flink的检查点路径是hdfs绝对路径,类似于 hdfs://address:port/path ,但是当hdfs处于ha模式时,如何为hdfs namenode url change设置flink配置?

wvyml7n5

wvyml7n51#

使用hadoopha,建议使用clusteridhdfs://nameservice_id/path/file.use 此uri而不是'hdfs://activenamenodehost/path希望这有帮助。
使用hdfs://uri时如何在此处设置:namenode ha。
更多详情请参见:https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/hdfshighavailabilitywithqjm.html

相关问题