问答 2023-04-03 来自:开发者社区

FlinkSink写到hdfs的文件,不是part开头,而是以 . 开头的文件。请问这个是怎么回事?

FlinkSink写到hdfs的文件,不是part开头,而是以 . 开头的文件。请问这个是怎么回事?

问答 2023-03-08 来自:开发者社区

我想使用FlinkSink写hdfs使用snappy压缩代码是这样写(参考下列)提交后报错是为什么?

我想使用FlinkSink写hdfs。使用snappy压缩。 代码是这样写的: CompressWriterFactory writer = CompressWriters.forExtractor(new DefaultExtractor()) .withHadoopCompression(codec, conf); FileSink sink = FileSink ...

问答 2023-01-16 来自:开发者社区

Flinksink hdfs 压缩的时候会报这个错,你们遇见过嘛?

Flinksink hdfs 压缩的时候会报这个错,你们遇见过嘛?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。