The StreamingFileSink can have a OutputFileConfig [1] to config the prefix and suffix of the part file, does that work for you ?
[1] https://github.com/apache/flink/blob/1d9d0bf582a79ed5cba4ec096e9c12fe5618bcf7/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java#L71 Best, Danny Chan 在 2020年5月14日 +0800 AM2:05,dhurandar S <dhurandarg...@gmail.com>,写道: > > StreamFileSink