flink的检查点路径是hdfs绝对路径,类似于 hdfs://address:port/path ,但是当hdfs处于ha模式时,如何为hdfs namenode url change设置flink配置?
hdfs://address:port/path
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
1条答案
按热度按时间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