Re: Can JDBCSinkFunction support exectly once?

Posted by Dominik Wosiński on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Can-JDBCSinkFunction-support-exectly-once-tp24636p24639.html

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 <[hidden email]> 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