增加测试用例

Author: 5herhom

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java

@@ -210,12 +210,14 @@ public int compareTo(BinlogOffset that) {
                 // ...
                 return gtidSet.isContainedWithin(targetGtidSet) ? -1 : 1;
             }
+
+            // The GTIDs are the same, so compare the completed events in the transaction ...
             long restartSkipEvents = this.getRestartSkipEvents();
             long targetRestartSkipEvents = that.getRestartSkipEvents();
-            // The positions are the same, so compare the completed events in the transaction ...
             if (restartSkipEvents != targetRestartSkipEvents) {
                 return Long.compare(restartSkipEvents, targetRestartSkipEvents);
             }
+
             // The completed events are the same, so compare the row number ...
             return Long.compare(this.getRestartSkipRows(), that.getRestartSkipRows());
         } else if (StringUtils.isNotEmpty(gtidSetStr)) {