flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From XW Marvin <marvin....@gmail.com>
Subject flink to hdfs StreamingFileSink.forBulkFormat file rename
Date Tue, 08 Oct 2019 10:42:50 GMT
补充下问题

Flink 1.9.0

1. 使用StreamingFileSink 消费kafka数据到HDFS
2. 开启了EXACTLY_ONCE
3. StreamingFileSink.forBulkFormat,Parquet格式、snappy压缩

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

如何重命名啊?
Mime
View raw message