flink StreamingFileSink to HDFS 修改文件名字

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

flink StreamingFileSink to HDFS 修改文件名字

XW Marvin
flink 1.9.0

1. 使用StreamingFileSink 消费kafka数据到HDFS
2. 开启了EXACTLY_ONCE

写入hdfs的文件都是
part-{parallel-task}-{count}
这种格式

如何重命名啊?