Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35128

Re-calculate the starting change log offset after the new table added

    XMLWordPrintableJSON

Details

    Description

      In mysql cdc, re-calculate the starting binlog offset after the new table added in MySqlBinlogSplit#appendFinishedSplitInfos, while there lack of same action in StreamSplit#appendFinishedSplitInfos. This will cause data loss if any newly added table snapshot split's highwatermark is smaller.

       

      Some unstable test problem occurs because of it.

      Attachments

        Issue Links

          Activity

            People

              loserwang1024 Hongshun Wang
              loserwang1024 Hongshun Wang
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: