flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 王佩 <wang...@cmcm.com>
Subject StreamingFileSink自定义输出的文件名
Date Tue, 30 Jul 2019 03:51:27 GMT
用StreamingFileSink.forBulkFormat写到HDFS上的文件,默认文件名为
part-subtaskID-bucketID,如: part-3-62529。

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

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


感谢!辛苦!
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message