Hey, As far as I know, the function needs to implement the *TwoPhaseCommitFunction* and not the *CheckpointListener. JDBCSinkFunction *does not implement the two-phase commit, so currently it does not support exactly once.
Best Regards, Dom. śr., 21 lis 2018 o 11:07 Jocean shi <jocean....@gmail.com> napisał(a): > Hi, > Can JDBCSinkFunction support exectly once? Is it that The JDBCSinkFunction > dont't implement CheckpointListener meaning JDBCSinkFunction dont't support > exectly once? > > cheers > > Jocean >
