You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/04/30 02:05:24 UTC

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

不写具体地址按fs.defaultFS中的来



------------------&nbsp;原始邮件&nbsp;------------------
发件人: "196371551"<196371551@qq.com&gt;; 
发送时间: 2020年4月30日(星期四) 上午8:50
收件人: "user"<user@flink.apache.org&gt;; "user-zh"<user-zh@flink.apache.org&gt;; 
主题: flink实时写入hdfs parquest,hdfs做了ha该怎么处理



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