e-mhui opened a new pull request, #8308:
URL: https://github.com/apache/inlong/pull/8308

   ### Prepare a Pull Request
   
   [INLONG-8307][Sort] Fix job restart failed from savepoint When set 
'scan.startup.mode' = 'timestamp|earliest-offset|specific-offset'
   
   - Fixes #8307 
   
   ### Motivation
   
   When set 'scan.startup.mode' = 'timestamp|earliest-offset|specific-offset', 
it will assign an incorrect GTID, when restart from Savepoint, the incorrect 
GTID will lead failure of the job. We should adjusted GTID to ensure the 
completeness. More details refer for: 
https://github.com/ververica/flink-cdc-connectors/pull/2220.
   
   ### Modifications
   
   1. Fix RestoredGtidSet in the MySqlOffsetContext.
   2. Adjust GTID merging logic to support recovering from job which previously 
specifying starting offset on start.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to