我在scala 中有一个方法
counts.writeAsText(path_to_file)
当文件已经存在时，它抛出一个异常，并建议指定CCD_ 2。但是我在DataStream类中还没有找到一个接受org.apache.flink.core.fs.FileSystem.WriteMode的方法。只有一个签名在毫秒内接受Long。
Scala API当前缺少带有相应WriteMode参数的重载。这是一个错误，将被修复。
同时，您可以始终通过fs.overwrite-files配置参数控制Flink的默认覆盖行为。如果在flink-conf.yaml中将此参数设置为fs.overwrite-files: true，则写入文件将始终覆盖。
相应JIRA问题的状态可以在此处找到。
请注意：现在已经修复了。您可以调用.writeAsText(filePath, org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE)