Will StreamingFileSink.forBulkFormat(...) support overriding OnCheckpointRollingPolicy?

2019-07-22 Thread Elkhan Dadashov
Hi Flink Dev team, Will StreamingFileSink.forBulkFormat(...) support overriding OnCheckpointRollingPolicy? Does anyone use StreamingFileSink *with checkpoint disabled *for writing Parquet output files? The output parquet files are generated, but they are empty, and stay in *inprogress* state

Re: Will StreamingFileSink.forBulkFormat(...) support overriding OnCheckpointRollingPolicy?

2019-07-23 Thread Till Rohrmann
ssing guarantees. Klou might know more. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/streamfile_sink.html Cheers, Till On Mon, Jul 22, 2019 at 10:21 PM Elkhan Dadashov wrote: > Hi Flink Dev team, > > Will StreamingFileSink.forBulkFormat(...) supp

Re: Will StreamingFileSink.forBulkFormat(...) support overriding OnCheckpointRollingPolicy?

2019-07-23 Thread Kostas Kloudas
guarantees. Klou > might know more. > > [1] > https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/streamfile_sink.html > > Cheers, > Till > > On Mon, Jul 22, 2019 at 10:21 PM Elkhan Dadashov < > elkhan.dadas...@gmail.com> wrote: > >>