flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

com.ververica.cdc.connectors.oracle.OracleValidator@2bbf180e is not serializable

Open szgyh opened this issue 4 years ago • 3 comments

Describe the bug A clear and concise description of what the bug is.

Environment :

  • Flink version : 1.3
  • Flink CDC version: 2.1
  • Database and version: oracle12

用官方的例子oracle api 报错,com.ververica.cdc.connectors.oracle.OracleValidator没有实现序列化接口,不能序列化

Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: com.ververica.cdc.connectors.oracle.OracleValidator@2bbf180e is not serializable. The object probably contains or references non serializable fields. at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:164) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:132) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:69) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:2053) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1737) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1720) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1689) at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1675) at com.atguigu.OracleSourceExample.main(OracleSourceExample.java:25) Caused by: java.io.NotSerializableException: com.ververica.cdc.connectors.oracle.OracleValidator at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184) at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348) at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:624) at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:143) ... 8 more Disconnected from the target VM, address: '127.0.0.1:60186', transport: 'socket'

Process finished with exit code 1

szgyh avatar Dec 01 '21 09:12 szgyh

2.1.0是实现了Serializable接口的,应该是其他问题;

ashulin avatar Dec 02 '21 04:12 ashulin

我也出现了同样的问题,已经解决,原因是我的工程里同时还有2.0.0的mysql-connector,有冲突,去掉mysql或者把mysql-connector的版本升到和orcale-connector版本相同,问题就解决了。

nayoaixgnat avatar Jan 21 '22 09:01 nayoaixgnat

Closing this issue as it is no longer valid or requires additional information. If the issue still exists, please report it on Apache Jira under the project Flink, using the component tag Flink CDC. Thank you! cc @GOODBOY008

gong avatar Feb 03 '24 06:02 gong

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!

PatrickRen avatar Feb 28 '24 15:02 PatrickRen