Folks any idea on this? On Wed, 15 Jan 2025 at 7:08 AM, Taher Koitawala <taher...@gmail.com> wrote:
> 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 >> >
