我在
scala中有一个方法

 counts.writeAsText(文件路径)

当文件已存在并建议指定时,它会抛出异常
文件或目录已存在.在NO_OVERWRITE模式下不会覆盖现有文件和目录.使用OVERWRITE模式覆盖现有的文件和目录..但是我没有在DataStream类中找到一个接受org.apache.flink.core.fs.FileSystem.WriteMode的方法.只有一个签名可以接受Long为毫秒.

最佳答案
Scala API目前缺少相应WriteMode参数的重载.这是一个错误,将被修复.

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

相应的JIRA问题的状态可以在here找到.