Cannot load user class: com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction

[macho678]

tidb： 6.1.5
Flink： 1.13
tidb cdc：tidb-cdc-2.2.0

Does anyone have encountered this error, please help analyze（ start job）.
2023-03-17 19:43:58,723 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: TableSourceScan(table=[[default_catalog, default_database, bc_bet_records]], fields=[id, record_id, order_no, round_id, platform_id, category_id, site_code, site_prefix, agent_code, account, third_user_name, pull_time, third_game_code, all_bet, valid_bet, net_profit, rake, jackpot, bet_time, bet_time_stamp, settle_time, settle_time_stamp, settle_status, device, bet_ip, third_group_code, after_balance, is_combo, odds_type, odds, order_status, sports_type, winlost_time, game_id, currency, settle_time_zone, version_no, id_bettime_key]) (1/1) (11575f87065b330f2d6a86cc92ed1f01) switched from INITIALIZING to FAILED on 10.65.20.252:41871-b3f722 @ 10.65.20.252 (dataPort=35005).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction
ClassLoader info: URL ClassLoader:
Class not resolvable through given classloader.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:336) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:159) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:548) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_362-362]
Caused by: java.lang.ClassNotFoundException: com.ververica.cdc.connectors.tidb.TiKVRichParallelSourceFunction
at java.net.URLClassLoader.findClass(URLClassLoader.java:387) ~[?:1.8.0_362-362]
at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_362-362]
at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:64) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_362-362]
at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:172) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at java.lang.Class.forName0(Native Method) ~[?:1.8.0_362-362]
at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_362-362]
at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:76) ~[flink-dist_2.12-1.13.2.jar:1.13.2]
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1988) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1852) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2186) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2213) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1669) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2431) ~[?:1.8.0_362-362]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2355) ~[?:1.8.0_362-362]