[ 
https://issues.apache.org/jira/browse/FLINK-11928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Dawid Wysakowicz closed FLINK-11928.
------------------------------------
    Resolution: Won't Fix

Closing it as it addresses deprecated {{BucketingSink}} which is subsumed by 
the {{StreamingFileSink}}, which as far as I know supports compresssion, as 
[~gaoyunhaii] mentioned.

> Create a Compression string writer for flink-connectors-filesystem
> ------------------------------------------------------------------
>
>                 Key: FLINK-11928
>                 URL: https://issues.apache.org/jira/browse/FLINK-11928
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / FileSystem
>    Affects Versions: 1.6.3, 1.7.2
>            Reporter: Shengnan YU
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Flink does not provided a API for writer compressed string text file to 
> filesystem. I have implemented a simple CompressionStringWriter can 
> compressed the stream and write to the FS. The default writing is to call 
> toString() method for element and separate them by newline. Extending this 
> class and override write() method can make custom writting.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to