flink 1.9.0

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

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

如何重命名啊?

回复