????flink??????????????????????????????flink????????????????????TwoPhaseCommitSinkFunction??????????????????????????,
?C beginTransaction ?C preCommit ?C commit ?C abort ????sink??????????????????????????????????????????????????????MYSQL???????????????????????????????????????? preCommit?????????? ????????commit??????????????????????????????????checkpoint??????????????????checkpoint???????????????????????????????????????????????? ????????checkpoint??????????????????????????????????checkpoint???????????????????????????????????????? ????????????????????????checkpoint?????????????????????????????????????????????????? ????????????????????????????????????
