开发者社区> 问答> 正文

flink 写parquet格式,使用StreamingFileSink 时报错

flink 写parquet格式,使用StreamingFileSink 时报错java.lang.UnsupportedOperationException: Recoverable writers on Hadoop are only supported for HDFS and for Hadoop version 2.7 or newer

可有其他解决方案么

展开
收起
游客vwsocr6vjxidc 2019-11-11 10:38:09 1268 0
1 条回答
写回答
取消 提交回答
  • 目前从事大数据开发,兼顾平台搭建以及实时数据分析,主要是用scala编写程序,涉及社区开源hadoop集群,emr集群,欢迎有相同兴趣的小伙伴来交流,共同进步。最近在参与flink-java实时开发。

    麻烦题主提供一下flink 、 jdk 、 kafka 、 hadoop的版本。 根据仅有的报错信息,使用的 Writers 是不支持当前的文件系统或者hadoop版本。

    2019-11-13 12:55:26
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载