??????????: Re: Flink????Kafka??Mysql?? End-To-End Exactly-Once????????????

2020-08-02 文章 ?????? 
MySQL??Connection??
??Connection A T ??commit()Connection 
A??A TwoPhaseCommitSinkFunction 
pendingCommitTransactions??Connection 
BcommitT


??MySQL??2PC??





--  --
??: 
   "user-zh"

https://github.com/lusecond/flink_help --depth=1
> >
> >
> > 
TwoPhaseCommitSinkFunction4??beginTransaction??preCommit??commit??abort
> > 
jdbc

?????? Flink????Kafka??Mysql?? End-To-End Exactly-Once????????????

2020-01-02 文章 ????2008 
??1??mysql-connector-java??latest
??5.1.6??
5.1.48
https://github.com/lusecond/flink_help --depth=1
>
>
> 
TwoPhaseCommitSinkFunction4??beginTransaction??preCommit??commit??abort
> 
jdbc