检查点路径和 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