如何在Apache Flink Streaming 0.10.0中为OVERWRITE指定writeAsText？

Question

我在scala中有一种方法

counts.writeAsText(path_to_file)

当文件已经存在并建议指定时，它将引发异常 File or directory already exists. Existing files and directories are not overwritten in NO_OVERWRITE mode. Use OVERWRITE mode to overwrite existing files and directories.。但是我没有在DataStream类中找到可以接受的方法org.apache.flink.core.fs.FileSystem.WriteMode。只有一个签名可以接受Long毫秒。

Answer 1

Scala API 目前缺少相应参数的重载WriteMode。这是一个错误，将被修复。

同时，您始终可以通过fs.overwrite-files配置参数控制 Flink 的默认覆盖行为。fs.overwrite-files: true如果您在 中设置此参数flink-conf.yaml，则写入文件将始终被覆盖。

可以在此处找到相应 JIRA 问题的状态。