flink-cdc
flink-cdc copied to clipboard
Oracle add data has error
Search before asking
- [X] I searched in the issues and found nothing similar.
Flink version
1.18.1
Flink CDC version
3.0.0
Database and its version
oracle 11g
Minimal reproduce step
I run the document at https://ververica.github.io/flink-cdc-connectors/release-3.0/content/connectors/oracle-cdc.html,when i add a data to table,it has some error
Properties debeziumProperties = new Properties();
debeziumProperties.setProperty("log.mining.strategy", "online_catalog");
debeziumProperties.setProperty("include.schema.changes", "true");
debeziumProperties.setProperty("value.converter.schemas.enable", "true");
OracleSourceBuilder.OracleIncrementalSource oracleChangeEventSource =
new OracleSourceBuilder()
.hostname("hostname")
.port(1521)
.databaseList("ORCL")
.schemaList("FLINKUSER")
.tableList("FLINKUSER.CREATETABLE")
.username("flinkuser")
.password("flinkpw")
.deserializer(new JsonDebeziumDeserializationSchema())
.includeSchemaChanges(true) // output the schema changes as well
.startupOptions(StartupOptions.initial())
.debeziumProperties(debeziumProperties)
.splitSize(2)
.build();
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(3000L);
DataStreamSource oracleChangeEventStream = env.fromSource(
oracleChangeEventSource,
WatermarkStrategy.noWatermarks(),
"OracleParallelSource")
.setParallelism(4)
.setParallelism(1);
oracleChangeEventStream.print();
What did you expect to see?
Is it my configuration problem
What did you see instead?
null error
Anything else?
No response
Are you willing to submit a PR?
- [X] I'm willing to submit a PR!
When i add column at table,id has other error.
Closing this issue as it has been migrated to Apache Jira.