This 'committedEvents' queue should have an initial capacity.

[lantuxin]

flink-cdc/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java

Line 141 in 24ab548

committedEvents = new LinkedBlockingQueue<>();

If a table in TiDB changes a large number of rows, and committedEvents doesn't have an initial capacity, more and more data will be added to this queue, eventually consuming all of the TM's memory and causing an OOM.