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
