flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yanggang_it_job <yanggang_it_...@163.com>
Subject 文件重命名
Date Tue, 08 Oct 2019 09:39:49 GMT
Dear All


Flink 1.9.0


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


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


如何重命名啊?


Best
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message