Re: Mongodb_sink

First of all, mongodb itself does not support transactions. But you can init a buffer to save each row when transaction begins, and save all the buffered records to database once when transaction completes. C DINESH 于2020年7月15日周三 上午9:28写道： > Hello all, > > Can we implement TwoPhaseCommitPro

Mongodb_sink

Hello all, Can we implement TwoPhaseCommitProtocol for mongodb to get EXACTLY_ONCE semantics. Will there be any limitation for it? Thanks, Dinesh.