[FLINK-34871] Oracle add data has error

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Flink CDC
• Labels: github-import
• Assignee: Unassigned
• Reporter: Flink CDC Issue Import
• Created: 20/Mar/24 09:34
• Updated: 20/Mar/24 09:34

Description

1. 1. 1. Search before asking

• [X] I searched in the [issues|https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar.

1. 1. 1. Flink version

1.18.1

1. 1. 1. Flink CDC version

3.0.0

1. 1. 1. Database and its version

oracle 11g

1. 1. 1. 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(];

!image

1. 1. 1. What did you expect to see?

Is it my configuration problem

1. 1. 1. What did you see instead?

null error

1. 1. 1. Anything else?

No response

1. 1. 1. Are you willing to submit a PR?

• [X] I'm willing to submit a PR!

---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/3056
Created by: ccczhouxin
Labels: bug,
Created at: Fri Feb 02 10:05:38 CST 2024
State: open