flink实时写入hdfs parquest,hdfs做了ha该怎么处理

[196371551]

hI：
    我现在把kafka和es的数据实时读取写入hdfs目录下，但是我的hdfs做了ha，NameNode会切换，我在flink作业中配置的hdfs目录是hdfs://xx:8020/xxxx，切换了NameNode，任务就会报错