"有遇到过flink-sql-connector-tidb-cdc报NPE的吗？看代码注释是丢cdc

"有遇到过flink-sql-connector-tidb-cdc报NPE的吗？看代码注释是丢cdc event了。2023-03-29 14:42:33,255 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: xxxx_src[1] (1/1) (2b2369ccab278c50b0162ba9a76c771a_bc764cd8ddf7a0cff126f51c16239658_0_3) switched from RUNNING to FAILED on container_e08_1667061160457_17606_01_000004 @ ssss (dataPort=38635). java.lang.NullPointerException: null at java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:411) ~[?:1.8.0_332] at com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.flushRows(TiKVRichParallelSourceFunction.java:261) ~[flink-sql-connector-tidb-cdc-2.3.0.jar:2.3.0] at com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.readChangeEvents(TiKVRichParallelSourceFunction.java:248) ~[flink-sql-connector-tidb-cdc-2.3.0.jar:2.3.0] at com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.run(TiKVRichParallelSourceFunction.java:167) ~[flink-sql-connector-tidb-cdc-2.3.0.jar:2.3.0] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) ~[flink-dist-1.16.1.jar:1.16.1] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) ~[flink-dist-1.16.1.jar:1.16.1] at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:333) ~[flink-dist-1.16.1.jar:1.16.1] 2023-03-29 14:42:33,257 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - 2 tasks will be restarted to recover the failed task 2b2369ccab278c50b0162ba9a76c771a_bc764cd8ddf7a0cff126f51c16239658_0_3. 2023-03-30 11:36:43,319 WARN org.apache.flink.runtime.taskmanager.Task [] - Source: xxx_src [21] (1/1)#0 (3c7b0c0cb2d908cf4a7a670f7f7c7bbf_bf09cf35399d5c5c03a80cb650d87bb9_0_0) switched from RUNNING to FAILED with failure cause: java.lang.NullPointerException at org.tikv.common.codec.TableCodecV2.decodeObjects(TableCodecV2.java:58) at org.tikv.common.codec.TableCodec.decodeObjects(TableCodec.java:50) at com.ververica.cdc.connectors.tidb.table.RowDataTiKVSnapshotEventDeserializationSchema.deserialize(RowDataTiKVSnapshotEventDeserializationSchema.java:67) at com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.readSnapshotEvents(TiKVRichParallelSourceFunction.java:211) at com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction.run(TiKVRichParallelSourceFunction.java:157) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:333) "