I can see two ways of achieving this:
1. Setting a suffix* **only*** for the completed part files. I don't
necessarily think the suffix should be added for the intermediate files (as
intermediate files should not really be ready for consumption by a
2. Be able to override this partPath name creation -https://github.com/apache/flink/blob/release-1.4.0/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java#L523
. That way any user who needs to set a custom/dynamic part file name can
still do so.
Do you think either or one of these options is feasible?
On Tue, Apr 3, 2018 at 12:57 AM, Aljoscha Krettek <[EMAIL PROTECTED]>
*Lakshmi Gururaja Rao*
[image: Lyft] <http://www.lyft.com/>