The StreamingFileSink can have a OutputFileConfig [1] to config the prefix and
suffix of the part file, does that work for you ?
[1]
https://github.com/apache/flink/blob/1d9d0bf582a79ed5cba4ec096e9c12fe5618bcf7/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/file
Yes we looked at it ,
The problem is the file name gets generated in a dynamic fashion, based on
which organization data we are getting we generate the file name from the
coming data.
Is there any way we can achieve this ??
On Tue, May 12, 2020 at 8:38 PM Yun Gao wrote:
> Hi Dhurandar:
>
>
