[jira] [Comment Edited] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink)

["yitzchak lieberman (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845581#comment-16845581 ] 

yitzchak lieberman edited comment on FLINK-12573 at 5/22/19 6:43 AM:
---------------------------------------------------------------------

Hi Louis.

I think it could help if it will be parameterized like in BucketingSink, in order to set different suffix when application restarts.

My thought was like:

new Path(bucketPath, PART_PREFIX + subtaskIndex + partCounter + new UUID() + <file type extention (like - ".parquet")>) 

or:

new Path(bucketPath, PART_PREFIX + subtaskIndex + partCounter + suffix)


was (Author: yitz589):
Hi Louis.

I think it could help if it will be parameterized like in BucketingSink, in order to set different suffix when application restarts.

My thought was like:

new Path(bucketPath, PART_PREFIX + subtaskIndex + partCounter + new UUID() + <file type extention (like - ".parquet")>)

> ability to add suffix to part file created in Bucket (StreamingFileSink)
> ------------------------------------------------------------------------
>
>                 Key: FLINK-12573
>                 URL: https://issues.apache.org/jira/browse/FLINK-12573
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / FileSystem
>    Affects Versions: 1.8.0
>            Reporter: yitzchak lieberman
>            Assignee: Louis Xu
>            Priority: Major
>
> a possibility to add suffix to part file path other than:
> new Path(bucketPath, PART_PREFIX +  -- subtaskIndex + partCounter);
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)