Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink to hdfs StreamingFileSink.forBulkForma
t file rename
Classic
List
Threaded
♦
♦
Locked
1 message
XW Marvin
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
flink to hdfs StreamingFileSink.forBulkForma
t file rename
补充下问题
Flink 1.9.0
1. 使用StreamingFileSink 消费kafka数据到HDFS
2. 开启了EXACTLY_ONCE
3. StreamingFileSink.forBulkFormat,Parquet格式、snappy压缩
写入hdfs的文件都是
part-{parallel-task}-{count}
这种格式
如何重命名啊?
Free forum by Nabble
Edit this page