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