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
downstream process?)
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?

Thanks
Lakshmi

On Tue, Apr 3, 2018 at 12:57 AM, Aljoscha Krettek <[EMAIL PROTECTED]>
wrote:
--
*Lakshmi Gururaja Rao*
SWE
217.778.7218 <+12177787218>
[image: Lyft] <http://www.lyft.com/>