HA 名称节点配置的 hdfs 上的 Flink 检查点


flink 的

检查点路径和 hdfs://address:port/path 一样是 hdfs 的绝对路径,但是当 hdfs 处于 HA 模式时,如何设置 hdfs 名称节点 url 更改的 flink 配置?

建议使用 Hadoop HA ,clusterId。这样做之后,URI 看起来像这样 hdfs://nameservice_id/path/file。使用此 URI 而不是"hdfs://activeNamenodeHost/path"。希望这有帮助。

如何在此处设置:使用 hdfs://URI 时的名称节点 HA。

更多详情请见这里 : https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/HDFSHighAvailabilityWithQJM.html

最新更新