Re: Can JDBCSinkFunction support exectly once?

2018-11-21 Thread Jocean shi
e 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

Can JDBCSinkFunction support exectly once?

2018-11-21 Thread Jocean shi
Hi, Can JDBCSinkFunction support exectly once? Is it that The JDBCSinkFunction dont't implement CheckpointListener meaning JDBCSinkFunction dont't support exectly once? cheers Jocean