Can someone please help with this? On Fri 25 Jan, 2019, 1:47 PM Taher Koitawala <taher.koitaw...@gslab.com wrote:
> Hi All, > Is there a way to specify *batch size* and *compression *properties > when using StreamingFileSink just like we did in bucketing sink? The only > parameters it is accepting is Inactivity bucket check interval and avro > schema. > > We have numerous flink jobs pulling data from the same kafka > topics, however doing different operations. And each flink job is writing a > file with different size and we would want to make it consistent. > > > Regards, > Taher Koitawala > GS Lab Pune > +91 8407979163 >
