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
