branch-4.1: [Improve](job) update flink cdc version for streaming job #62212 (#62430)

Cherry-picked from #62212

Co-authored-by: wudi <wudi@selectdb.com>

Author: github-actions[bot]

fe/fe-core/src/main/java/org/apache/doris/job/offset/jdbc/JdbcSourceOffsetProvider.java

@@ -431,9 +431,7 @@ public void replayIfNeed(StreamingInsertJob job) throws JobException {
     protected List<SnapshotSplit> recalculateRemainingSplits(
             Map<String, Map<String, Map<String, String>>> chunkHighWatermarkMap,
             Map<String, List<SnapshotSplit>> snapshotSplits) {
-        if (this.finishedSplits == null) {
-            this.finishedSplits = new ArrayList<>();
-        }
+        this.finishedSplits = new ArrayList<>();
         for (Map.Entry<String, Map<String, Map<String, String>>> entry : chunkHighWatermarkMap.entrySet()) {
             String tableId = entry.getKey();
             Map<String, Map<String, String>> splitIdToHighWatermark = entry.getValue();

fs_brokers/cdc_client/pom.xml

@@ -63,6 +63,7 @@ under the License.
     <properties>
         <spring.version>3.5.7</spring.version>
         <flink.version>1.20.3</flink.version>
+        <flink.cdc.version>3.6.0-1.20</flink.cdc.version>
         <slf4j.version>1.7.36</slf4j.version>
         <doris.version>1.2-SNAPSHOT</doris.version>
         <spotless.version>2.43.0</spotless.version>
@@ -118,12 +119,12 @@ under the License.
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-connector-mysql-cdc</artifactId>
-            <version>3.5.0</version>
+            <version>${flink.cdc.version}</version>
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-connector-postgres-cdc</artifactId>
-            <version>3.5.0</version>
+            <version>${flink.cdc.version}</version>
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>