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

Flink checkpoint on hdfs of HA namenode config

flink的checkpoint路径和hdfs://address:port/path一样是hdfs的绝对路径,但是当hdfs处于HA模式时,如何设置hdfs namenode的flink配置url变化?

使用 Hadoop HA,clusterId 是 recommended.After 这样做,URI 看起来像这样 hdfs://nameservice_id/path/file。使用这个 URI 而不是 'hdfs://activeNamenodeHost/path'。希望这有帮助。

这里如何设置:NameNode HA when using hdfs:// URI.

此处有更多详细信息:https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/HDFSHighAvailabilityWithQJM.html