Flink контрольная точка на hdfs конфигурации HA namenode

Question

Путь контрольной точки flink - это абсолютный путь hdfs, такой как hdfs://address:port/path, но когда hdfs находится в режиме HA, как установить конфигурацию flink для изменения URL-адреса namenode hdfs?

Answer 1

При использовании Hadoop HA рекомендуется clusterId. После этого URI выглядит следующим образом: hdfs: //nameservice_id/path/file.Use этот URI вместо 'hdfs: //activeNamenodeHost/path'.Надеюсь, это поможет.

Как установить здесь: NameNode HA при использовании hdfs: // URI .

Подробнее здесь: https://hadoop.apache.org/docs/r2.7.0/hadoop-project-dist/hadoop-hdfs/HDFSHighAvailabilityWithQJM.html