我在scala中有一个方法
counts.writesText文件(路径u到u文件)
当文件已经存在并建议指定
我在scala中有一个方法
counts.writesText文件(路径u到u文件)
当文件已经存在并建议指定
Scala API当前缺少具有相应WriteMode参数的重载。这是一个错误,将被修复。
同时,您可以通过fs.覆盖-文件配置参数。如果将此参数设置为fs.覆盖-档案:在你的flink里是真的-形态亚马尔,则写入文件将始终覆盖。
相应的JIRA问题的状态可以在这里找到。
请注意:这个问题现在已经解决了。您可以调用.writesText(文件路径,网址:apache.flink.core.fs.文件系统.WriteMode.OVERWRITE文件)