java.lang.NullPointerException: null at com.ververica.cdc.debezium.DebeziumSourceFunction.cancel(DebeziumSourceFunction.java:495) ~[flink-connector-mysql-cdc-2.0.0.jar:2.0.0]

[Ariel842]

Scala版本：2.11
Flink版本：1.12.2
Java 版本：1.8
用的cdc版本是2.0.0
项目报错：
[Source: Custom Source (1/1)#0] ERROR org.apache.flink.runtime.taskmanager.Task [] - Error while canceling task Source: Custom Source (1/1)#0.
java.lang.NullPointerException: null
at com.ververica.cdc.debezium.DebeziumSourceFunction.cancel(DebeziumSourceFunction.java:495) ~[flink-connector-mysql-cdc-2.0.0.jar:2.0.0]
at org.apache.flink.streaming.api.operators.StreamSource.cancel(StreamSource.java:358) ~[flink-streaming-java_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.cancelTask(SourceStreamTask.java:204) ~[flink-streaming-java_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.cancelTask(SourceStreamTask.java:185) ~[flink-streaming-java_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.cancel(StreamTask.java:722) ~[flink-streaming-java_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.runtime.taskmanager.Task.cancelInvokable(Task.java:1420) [flink-runtime_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:849) [flink-runtime_2.11-1.12.2.jar:1.12.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:573) [flink-runtime_2.11-1.12.2.jar:1.12.2]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281]

如何解决这个问题呢🤦🏻‍♀️