scala - Apache Flink Streaming 0.10.0 で writeAsText に OVERWRITE を指定するには?

Question

私は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 を受け入れる署名のみがあります。

Answer 1

Scala API には、現在、それぞれのWriteModeパラメーターのオーバーロードがありません。これはバグであり、修正される予定です。

fs.overwrite-files当面は、設定パラメータを介して Flink のデフォルトの上書き動作をいつでも制御できます。でこのパラメータをfs.overwrite-files: trueに設定flink-conf.yamlすると、ファイルへの書き込みは常に上書きされます。

対応する JIRA 課題のステータスは、こちらで確認できます。