scala-如何在Apache Flink Streaming 0.10.0中指定writesText的覆盖?


0

我在scala中有一个方法

counts.writesText文件(路径u到u文件)

当文件已经存在并建议指定

2 答案


0

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

同时,您可以通过fs.覆盖-文件配置参数。如果将此参数设置为fs.覆盖-档案:在你的flink里是真的-形态亚马尔,则写入文件将始终覆盖。

相应的JIRA问题的状态可以在这里找到。


0

请注意:这个问题现在已经解决了。您可以调用.writesText(文件路径,网址:apache.flink.core.fs.文件系统.WriteMode.OVERWRITE文件)


我来回答

写文章

提问题

面试题