Adding Flink community here just incase anyone has more info on this. On Tue, 14 Jan 2025 at 1:00 PM, Taher Koitawala <taher...@gmail.com> wrote:
> Hi All, > Been moving from Flink development to Beam development i want am > using FileIO parquet Io. > > Folks in Flink we could use streaming flink sink with checkpointing and be > rest assured that no duplicate data would fall to the sink because flink’s > streaming file sink would make sure of that with Kakfa. > > How would i do the same in Beam using FlinkRunner. Please can you all help > me apply this same ? Is there a specific way to pass streaming file sink to > FileIo? > > > Regards, > Taher koitawala >
