StreamFileSink落盘文件合并

classic Classic list List threaded Threaded
1 message Options
cs
Reply | Threaded
Open this post in threaded view
|

StreamFileSink落盘文件合并

cs
flink版本:1.10.1
任务并行度:3
目前需要将kafka的报文落成hdfs文件
落成的文件形式如下
part-0-1
part-1-1
part-1-2
...
问题:目前有办法将落盘的文件进行合并吗?