StreamingFileSink自定义输出的文件名

[王佩-2]

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

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

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


感谢！辛苦！

[Biao Liu]

貌似没有现成的办法，有人提了个相关的相关的 JIRA ticket [1]，可以关注下

1. https://issues.apache.org/jira/browse/FLINK-13428

Thanks,
Biao /'bɪ.aʊ/



On Tue, Jul 30, 2019 at 11:51 AM 王佩 <[hidden email]> wrote:

> 用StreamingFileSink.forBulkFormat写到HDFS上的文件，默认文件名为
> part-subtaskID-bucketID，如: part-3-62529。
>
> 现在想自定义输出的文件名，不用part-subtaskID-bucketID这种格式。但在Flink中没有找到入口可以自定义文件名。
>
> 请教下各位大大，怎么才能实现。
>
>
> 感谢！辛苦！
>