用StreamingFileSink.forBulkFormat写到HDFS上的文件,默认文件名为
part-subtaskID-bucketID,如: part-3-62529。

现在想自定义输出的文件名,不用part-subtaskID-bucketID这种格式。但在Flink中没有找到入口可以自定义文件名。

请教下各位大大,怎么才能实现。


感谢!辛苦!

回复