5

我在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 毫秒。

4

2 回答 2

3

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

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

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

于 2015-11-24T11:06:01.220 回答
2

请注意：此问题现已修复。你可以打电话.writeAsText(filePath, org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE)

于 2019-01-24T19:11:27.577 回答