Skip to content

Commit 13e511a

Browse files
beryllwwangjunbo
authored andcommitted
[FLINK-37120][cdc-source-connector] Add ending split chunk first to avoid TaskManager oom
1 parent f105578 commit 13e511a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -470,7 +470,7 @@ private List<ChunkRange> splitEvenlySizedChunks(
470470
}
471471
}
472472
// add the ending split
473-
splits.add(ChunkRange.of(chunkStart, null));
473+
splits.add(0, ChunkRange.of(chunkStart, null));
474474
return splits;
475475
}
476476

@@ -498,7 +498,7 @@ private List<ChunkRange> splitUnevenlySizedChunks(
498498
chunkEnd = nextChunkEnd(jdbc, chunkEnd, tableId, splitColumn, max, chunkSize);
499499
}
500500
// add the ending split
501-
splits.add(ChunkRange.of(chunkStart, null));
501+
splits.add(0, ChunkRange.of(chunkStart, null));
502502
return splits;
503503
}
504504

0 commit comments

Comments
 (0)