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

zhangminglei commented on FLINK-9411:
-------------------------------------

A short checkpoint time that whether lead to poor compression or not, I will 
give an actual production test under compression situation and as an attachment 
attached to FLINK-9407 in the next few days.

Actually, We having been using this PR (but not polished yet) in our production 
environment for a long time. And getting a very nice results ending that 
compared to spark streaming. I will put the test results in the form of 
attachments to FLINK-9407 as a reference. And what you are more concerned about 
the short checkpoint interval will lead to poor compression, yea I would agree 
but we need a test for it. Furthermore, we have all known that the longer 
snapshots interval, the lower performance impact of asynchronous or synchronous 
snapshotting we would get. So, I think people do not inclined to adopt short 
checkpoint intervals for getting a high throughput and low latency in most 
cases. For example, in our calculation of uv jobs, the checkpoint intervals is 
30 seconds. Anyway, I will still give a test results under the compression 
situation.

I suggest this PR can merge as a temporary solution to reduce the user's 
learning curve since some users already had used ```BucketingSink``` in their 
project and wants this functionality as we can see in the user mail list a few 
days ago.  And In a short time, they may not switch to a new sink 
```StreamingFileSink ``` . This may be one of the good reasons I think.

By the way, I will watch FLINK-9749 and the subtask FLINK-9753 soon and give 
more response in the next couple of days.

> Support parquet rolling sink writer
> -----------------------------------
>
>                 Key: FLINK-9411
>                 URL: https://issues.apache.org/jira/browse/FLINK-9411
>             Project: Flink
>          Issue Type: New Feature
>          Components: filesystem-connector
>            Reporter: zhangminglei
>            Assignee: Triones Deng
>            Priority: Major
>
> Like support orc rolling sink writer in FLINK-9407 , we should also support 
> parquet rolling sink writer.



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

Reply via email to